airflow.providers.amazon.aws.hooks.appflow

Classes

AppflowHook

Interact with Amazon AppFlow.

Module Contents

class airflow.providers.amazon.aws.hooks.appflow.AppflowHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsGenericHook[mypy_boto3_appflow.client.AppflowClient]

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.

See also

run_flow(flow_name, poll_interval=20, wait_for_completion=True, max_attempts=60)[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

  • max_attempts (int) – the number of polls to do before timing out/returning a failure.

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 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

Was this entry helpful?