git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Log external module into airflow log


For example this python operator

write_polylines_geo_data = PythonOperator(
task_id='write_geo_data_polylines',
provide_context=True,
python_callable=generate_geo_data_files_from_wkt_data_file,
op_args=[
polylines_staging_file_loc,
'pickle',
WGS54,
'geometry',
None,
(polylines_geojson_file_location, 'geojson', WGS54),
(polylines_shape_file_location, 'shape', MTM5
)
],
dag=dag
)

​
I would like to log actions done into the function
​"generate_geo_data_files_from_wkt_data_file"
would i need to define a logger in this function and then it should do the
trick ?