0

I want to obtain all the logs generated by a task within an operator, in order to send it to Slack when an error occurs with the on_failure_callback method.

I want to get and send the Task INFO/ERROR/WARNING log using on_failure_callback. Can I access this data using the context? something Like context.get('dag').default_args['owner']

All this enter image description here

Danieledu
  • 391
  • 1
  • 4
  • 19

0 Answers0