airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Martin Gauthier <gauthiermarti...@gmail.com>
Subject Re: Log external module into airflow log
Date Fri, 01 Jun 2018 18:33:12 GMT
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 ?

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message