Airflow Xcom //free\\ Here

XCom uses a database (e.g., MySQL, PostgreSQL) to store and retrieve messages. When a task wants to send a message to another task, it pushes the message to XCom. The receiving task can then pull the message from XCom.

print(f"Received: data and ret_val")

@task def push_task(**context): context['task_instance'].xcom_push(key='record_count', value=100) airflow xcom

from airflow.configuration import conf conf.set('core', 'xcom_backend', 'airflow.providers.amazon.aws.xcom.s3.S3XComBackend') XCom uses a database (e