usecases/image-processing/dags/2.0/image_processing.py [177:197]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    dag=dag,
)
duplicate_face = BashOperator(
    task_id='duplicate_face',
    bash_command='echo duplicate_face',
    dag=dag,
)
failure = BashOperator(
    task_id='failure',
    bash_command='echo failure',
    dag=dag,
)

parallel_processing = DummyOperator(
    task_id='parallel_processing',
    dag=dag,
)
add_face_index = PythonOperator(
    task_id='add_face_index',
    python_callable=add_face_index,
    provide_context=True,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



usecases/image-processing/dags/image_processing.py [179:199]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    dag=dag,
)
duplicate_face = BashOperator(
    task_id='duplicate_face',
    bash_command='echo duplicate_face',
    dag=dag,
)
failure = BashOperator(
    task_id='failure',
    bash_command='echo failure',
    dag=dag,
)

parallel_processing = DummyOperator(
    task_id='parallel_processing',
    dag=dag,
)
add_face_index = PythonOperator(
    task_id='add_face_index',
    python_callable=add_face_index,
    provide_context=True,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -