def push_batch_id_to_xcom()

in composer-dags/demo_pipeline_composer.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

                           def push_batch_id_to_xcom(**context):
                               context['task_instance'].xcom_push(key='batch-id', value=batch_id)