airflow.providers.amazon.aws.hooks.appflow

Module Contents

Classes

AppflowHook

Interact with Amazon Appflow, using the boto3 library.
class airflow.providers.amazon.aws.hooks.appflow.AppflowHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

Interact with Amazon Appflow, using the boto3 library. Hook attribute conn has all methods that listed in documentation.

See also

Additional arguments (such as aws_conn_id or region_name) may be specified and

are passed down to the underlying AwsBaseHook.

See also

AwsBaseHook

EVENTUAL_CONSISTENCY_OFFSET :int = 15[source]
EVENTUAL_CONSISTENCY_POLLING :int = 10[source]
conn()[source]

Get the underlying boto3 Appflow client (cached)

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

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

Was this entry helpful?