def push_batch_id_to_xcom()

in workflows-generator/composer-templates/dataproc_serverless_job_executor.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)