mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-01-06 00:40:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

feat(engine/api): implementation of child/parent workflow runs (#292)

Browse Source
This commit is contained in:
abelanger5
2024-03-26 08:52:52 -07:00
committed by abelanger5
parent 70a05f86cf
commit ad9e9aedbf
26 changed files with 1141 additions and 352 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
python-sdk/hatchet_sdk/clients/rest/api/workflow_api.py
View File

@@ -1699,6 +1699,8 @@ class WorkflowApi:
limit: Annotated[Optional[StrictInt], Field(description="The number to limit by")] = None,
event_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The event id to get runs for.")] = None,
workflow_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The workflow id to get runs for.")] = None,
parent_workflow_run_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The parent workflow run id")] = None,
parent_step_run_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The parent step run id")] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1726,6 +1728,10 @@ class WorkflowApi:
:type event_id: str
:param workflow_id: The workflow id to get runs for.
:type workflow_id: str
:param parent_workflow_run_id: The parent workflow run id
:type parent_workflow_run_id: str
:param parent_step_run_id: The parent step run id
:type parent_step_run_id: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
@@ -1754,6 +1760,8 @@ class WorkflowApi:
limit=limit,
event_id=event_id,
workflow_id=workflow_id,
parent_workflow_run_id=parent_workflow_run_id,
parent_step_run_id=parent_step_run_id,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
@@ -1784,6 +1792,8 @@ class WorkflowApi:
limit: Annotated[Optional[StrictInt], Field(description="The number to limit by")] = None,
event_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The event id to get runs for.")] = None,
workflow_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The workflow id to get runs for.")] = None,
parent_workflow_run_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The parent workflow run id")] = None,
parent_step_run_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The parent step run id")] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1811,6 +1821,10 @@ class WorkflowApi:
:type event_id: str
:param workflow_id: The workflow id to get runs for.
:type workflow_id: str
:param parent_workflow_run_id: The parent workflow run id
:type parent_workflow_run_id: str
:param parent_step_run_id: The parent step run id
:type parent_step_run_id: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
@@ -1839,6 +1853,8 @@ class WorkflowApi:
limit=limit,
event_id=event_id,
workflow_id=workflow_id,
parent_workflow_run_id=parent_workflow_run_id,
parent_step_run_id=parent_step_run_id,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
@@ -1869,6 +1885,8 @@ class WorkflowApi:
limit: Annotated[Optional[StrictInt], Field(description="The number to limit by")] = None,
event_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The event id to get runs for.")] = None,
workflow_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The workflow id to get runs for.")] = None,
parent_workflow_run_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The parent workflow run id")] = None,
parent_step_run_id: Annotated[Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]], Field(description="The parent step run id")] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1896,6 +1914,10 @@ class WorkflowApi:
:type event_id: str
:param workflow_id: The workflow id to get runs for.
:type workflow_id: str
:param parent_workflow_run_id: The parent workflow run id
:type parent_workflow_run_id: str
:param parent_step_run_id: The parent step run id
:type parent_step_run_id: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
@@ -1924,6 +1946,8 @@ class WorkflowApi:
limit=limit,
event_id=event_id,
workflow_id=workflow_id,
parent_workflow_run_id=parent_workflow_run_id,
parent_step_run_id=parent_step_run_id,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
@@ -1949,6 +1973,8 @@ class WorkflowApi:
limit,
event_id,
workflow_id,
parent_workflow_run_id,
parent_step_run_id,
_request_auth,
_content_type,
_headers,
@@ -1987,6 +2013,14 @@ class WorkflowApi:
_query_params.append(('workflowId', workflow_id))
if parent_workflow_run_id is not None:
_query_params.append(('parentWorkflowRunId', parent_workflow_run_id))
if parent_step_run_id is not None:
_query_params.append(('parentStepRunId', parent_step_run_id))
# process the header parameters
# process the form parameters
# process the body parameter

9
python-sdk/hatchet_sdk/clients/rest/models/workflow_run.py
View File

@@ -20,6 +20,7 @@ import json
from datetime import datetime
from pydantic import BaseModel, Field, StrictStr
from typing import Any, ClassVar, Dict, List, Optional
from typing_extensions import Annotated
from hatchet_sdk.clients.rest.models.api_resource_meta import APIResourceMeta
from hatchet_sdk.clients.rest.models.workflow_run_status import WorkflowRunStatus
from hatchet_sdk.clients.rest.models.workflow_run_triggered_by import WorkflowRunTriggeredBy
@@ -42,7 +43,9 @@ class WorkflowRun(BaseModel):
error: Optional[StrictStr] = None
started_at: Optional[datetime] = Field(default=None, alias="startedAt")
finished_at: Optional[datetime] = Field(default=None, alias="finishedAt")
__properties: ClassVar[List[str]] = ["metadata", "tenantId", "workflowVersionId", "workflowVersion", "status", "displayName", "jobRuns", "triggeredBy", "input", "error", "startedAt", "finishedAt"]
parent_id: Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]] = Field(default=None, alias="parentId")
parent_step_run_id: Optional[Annotated[str, Field(min_length=36, strict=True, max_length=36)]] = Field(default=None, alias="parentStepRunId")
__properties: ClassVar[List[str]] = ["metadata", "tenantId", "workflowVersionId", "workflowVersion", "status", "displayName", "jobRuns", "triggeredBy", "input", "error", "startedAt", "finishedAt", "parentId", "parentStepRunId"]
model_config = {
"populate_by_name": True,
@@ -122,7 +125,9 @@ class WorkflowRun(BaseModel):
"input": obj.get("input"),
"error": obj.get("error"),
"startedAt": obj.get("startedAt"),
"finishedAt": obj.get("finishedAt")
"finishedAt": obj.get("finishedAt"),
"parentId": obj.get("parentId"),
"parentStepRunId": obj.get("parentStepRunId")
})
return _obj