| get_flow_by_id | Get a flow by its ID. Args:
flow_id: ID of the flow to retrieve. |
| get_flow_by_name | Get a flow by its name. Args:
name: Name of the flow to retrieve. |
| list_flows | Get a list of flows from the Prefect API. Args:
limit: Maximum number of flows to return (default 20).
offset: Number of flows to skip (default 0). |
| search_flows | Search for flows by name and/or tags. Args:
name: Optional name to search for (case-insensitive contains match).
tags: Optional list of tags to filter by.
limit: Maximum number of flows to return (default 20). |
| get_flow_run_by_id | Get a flow run by its ID. Args:
flow_run_id: ID of the flow run to retrieve. |
| list_flow_runs | Get a list of flow runs from the Prefect API. Args:
limit: Maximum number of flow runs to return (default 20).
offset: Number of flow runs to skip (default 0).
flow_id: Optional ID of the flow to filter runs by. |
| search_flow_runs_by_state | Search for flow runs by state. Args:
state_type: Optional state type (e.g., "COMPLETED", "FAILED", "CRASHED").
state_name: Optional state name (e.g., "Completed", "Failed").
limit: Maximum number of flow runs to return (default 20). |
| cancel_flow_run | Cancel a flow run. Args:
flow_run_id: ID of the flow run to cancel. |
| get_deployment_by_id | Get a deployment by its ID. Args:
deployment_id: ID of the deployment to retrieve. |
| get_deployment_by_name | Get a deployment by its name. Args:
name: Name of the deployment to retrieve, in format "flow_name/deployment_name". |
| list_deployments | Get a list of deployments from the Prefect API. Args:
limit: Maximum number of deployments to return (default 20).
offset: Number of deployments to skip (default 0).
flow_id: Optional ID of the flow to filter deployments by. |
| search_deployments_by_status | Search for deployments by schedule status. Args:
is_schedule_active: Filter deployments by whether their schedule is active.
limit: Maximum number of deployments to return (default 20). |
| create_flow_run_from_deployment | Create a new flow run for the specified deployment. Args:
deployment_id: ID of the deployment or name in format 'flow_name/deployment_name'.
parameters: Dictionary with parameters for the flow run (optional).
name: Optional name for the flow run.
timeout: Timeout in seconds, 0 means no waiting for completion (default 0). |
| filter_flows | Filter flows based on specified criteria. Args:
filter_criteria: Dictionary with filter criteria according to Prefect API.
Example: {"flows": {"tags": {"all_": ["production"]}}} |
| filter_flow_runs | Filter flow runs based on specified criteria. Args:
filter_criteria: Dictionary with filter criteria according to Prefect API.
Example: {"flow_runs": {"state": {"type": {"any_": ["FAILED", "CRASHED"]}}}} |
| filter_deployments | Filter deployments based on specified criteria. Args:
filter_criteria: Dictionary with filter criteria according to Prefect API.
Example: {"deployments": {"is_schedule_active": {"eq_": true}}} |
| create_flow_run | Create a new flow run for the specified deployment (Legacy). Args:
deployment_id: ID of the deployment to create a run for.
parameters: Dictionary with parameters for the flow run (optional). |