usecases/image-processing/dags/1.10/image_processing.py [208:225]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    dag=dag,
)
persist_data = PythonOperator(
    task_id='persist_data',
    python_callable=persist_data,
    provide_context=True,
    dag=dag,
)


face_detection >> [photo_not_meet_requirement, check_duplicate, failure] 
check_duplicate >> [duplicate_face, failure, parallel_processing]
parallel_processing >> add_face_index >> persist_data
parallel_processing >> create_thumbnail >> persist_data


if __name__ == "__main__":
    dag.cli()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



usecases/image-processing/dags/2.0/image_processing.py [204:221]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    dag=dag,
)
persist_data = PythonOperator(
    task_id='persist_data',
    python_callable=persist_data,
    provide_context=True,
    dag=dag,
)


face_detection >> [photo_not_meet_requirement, check_duplicate, failure] 
check_duplicate >> [duplicate_face, failure, parallel_processing]
parallel_processing >> add_face_index >> persist_data
parallel_processing >> create_thumbnail >> persist_data


if __name__ == "__main__":
    dag.cli()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -