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 ?