chariot.awm package

Submodules

chariot.awm.models module

class chariot.awm.models.PodDetails(name: str, status: str)[source]

Bases: Base

name: str
status: str
class chariot.awm.models.Workflow(id: str, name: str, description: str, project_id: str, config: dict[str, Any] | None, created_at: datetime.datetime, created_by: str, updated_at: datetime.datetime, updated_by: str, deleted_at: datetime.datetime | None, deleted_by: str | None, dirty: bool | None)[source]

Bases: Base

config: dict[str, Any] | None
created_at: datetime
created_by: str
deleted_at: datetime | None
deleted_by: str | None
description: str
dirty: bool | None
id: str
name: str
project_id: str
updated_at: datetime
updated_by: str
class chariot.awm.models.WorkflowDetails(id: str, name: str, description: str, project_id: str, config: dict[str, Any] | None, created_at: datetime.datetime, created_by: str, updated_at: datetime.datetime, updated_by: str, deleted_at: datetime.datetime | None, deleted_by: str | None, dirty: bool | None, deployment: str, pods: list[chariot.awm.models.PodDetails])[source]

Bases: Workflow

deployment: str
pods: list[PodDetails]

chariot.awm.workflows module

chariot.awm.workflows.create_workflow(project_id: str, name: str, description: str, config: dict[str, Any], paused: bool = False) → Workflow[source]

Create a workflow for a project.

Parameters:

  • project_id (str) – Project id

  • name (str) – Name of the workflow

  • description (str) – Description of the workflow

  • config (Dict[str, Any]) – The workflow configuration

  • paused (bool) – Set to true to not create an agent process pod

Return type:

models.Workflow

chariot.awm.workflows.delete_workflow(workflow_id: str)[source]

Delete a workflow for a project.

Parameters:

workflow_id (str) – Workflow id

Return type:

None

chariot.awm.workflows.get_workflow(workflow_id: str) → WorkflowDetails[source]

Get a workflow for a project.

Parameters:

workflow_id (str) – Workflow id

Return type:

models.WorkflowDetails

chariot.awm.workflows.get_workflows(name: str | None = None, project_ids: list[str] | None = None, include_deleted: bool | None = None, limit: int | None = None, after_key: str | None = None) → Generator[Workflow, None, None][source]

List workflows matching the specified filters.

Parameters:

  • name (Optional[str]) – Partial, case-insensitive name filter

  • project_ids (Optional[List[str]]) – List of project ids to filter

  • include_deleted (Optional[bool]) – Set to True to include deleted workflows

  • limit (Optional[int]) – The max number of items to return

  • after_key (Optional[str]) – The pagination key to fetch more items

Return type:

Generator[models.Workflow, None, None]

chariot.awm.workflows.initialize_workflow_user(workflow_id: str, agent_name: str)[source]

Initialize a user for a particular workflow and agent.

Parameters:

  • workflow_id (str) – Workflow id

  • agent_name (str) – Agent name

Return type:

None

chariot.awm.workflows.update_workflow(workflow_id: str, name: str, description: str, config: dict[str, Any], paused: bool = False) → Workflow[source]

Update a workflow by the id.

Parameters:

  • workflow_id (str) – Workflow id

  • name (str) – Name of the workflow

  • description (str) – Description of the workflow

  • config (Dict[str, Any]) – The workflow configuration

  • paused (bool) – Set to true to not create an agent process pod

Return type:

models.Workflow

Module contents