Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

tests.system.amazon.aws.example_ssm

Attributes

DAG_ID

ROLE_ARN_KEY

sys_test_context_task

USER_DATA

log

test_context

test_run

Functions

create_instance_profile(role_name, instance_profile_name)

await_instance_profile_exists(instance_profile_name)

delete_instance_profile(instance_profile_name, role_name)

extract_instance_id(instance_ids)

build_run_command_kwargs(instance_id)

wait_until_ssm_ready(instance_id[, max_attempts, ...])

Waits for an EC2 instance to register with AWS Systems Manager (SSM).

Module Contents

tests.system.amazon.aws.example_ssm.DAG_ID = 'example_ssm'[source]
tests.system.amazon.aws.example_ssm.ROLE_ARN_KEY = 'ROLE_ARN'[source]
tests.system.amazon.aws.example_ssm.sys_test_context_task[source]
tests.system.amazon.aws.example_ssm.USER_DATA[source]
tests.system.amazon.aws.example_ssm.log[source]
tests.system.amazon.aws.example_ssm.create_instance_profile(role_name, instance_profile_name)[source]
tests.system.amazon.aws.example_ssm.await_instance_profile_exists(instance_profile_name)[source]
tests.system.amazon.aws.example_ssm.delete_instance_profile(instance_profile_name, role_name)[source]
tests.system.amazon.aws.example_ssm.extract_instance_id(instance_ids)[source]
tests.system.amazon.aws.example_ssm.build_run_command_kwargs(instance_id)[source]
tests.system.amazon.aws.example_ssm.wait_until_ssm_ready(instance_id, max_attempts=10, delay_seconds=15)[source]

Waits for an EC2 instance to register with AWS Systems Manager (SSM).

This may take over a minute even after the instance is running. Raises an exception if the instance is not ready after max_attempts.

tests.system.amazon.aws.example_ssm.test_context = None[source]
tests.system.amazon.aws.example_ssm.test_run[source]

Was this entry helpful?