Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook
Interact with Amazon Appflow.
Provide thin wrapper around boto3.client("appflow").
Additional arguments (such as aws_conn_id) may be specified and
are passed down to the underlying AwsBaseHook.
-
conn()[source]
Get the underlying boto3 Appflow client (cached).
-
run_flow(flow_name, poll_interval=20, wait_for_completion=True)[source]
Execute an AppFlow run.
- Parameters
flow_name (str) – The flow name
poll_interval (int) – Time (seconds) to wait between two consecutive calls to check the run status
wait_for_completion (bool) – whether to wait for the run to end to return
- Returns
The run execution ID
- Return type
str
-
update_flow_filter(flow_name, filter_tasks, set_trigger_ondemand=False)[source]
Update the flow task filter; all filters will be removed if an empty array is passed to filter_tasks.
- Parameters
flow_name (str) – The flow name
filter_tasks (list[mypy_boto3_appflow.type_defs.TaskTypeDef]) – List flow tasks to be added
set_trigger_ondemand (bool) – If True, set the trigger to on-demand; otherwise, keep the trigger as is
- Returns
None
- Return type
None
