我有一个python可调process_csv_entries用来处理csv文件条目.只有成功处理完所有条目后,我才希望我的任务成功完成.否则任务应该失败
def process_csv_entries(csv_file):
# Boolean
file_completely_parsed = <call_to_module_to_parse_csv>
return not file_completely_parsed
CSV_FILE=<Sets path to csv file>
t1 = PythonOperator(dag=dag,
task_id='parse_csv_completely',
python_operator=process_csv_entries,
op_args=[CSV_FILE])
无论返回值如何,t1似乎都成功完成.如何强制PythonOperator任务失败？