Is there any way of sending a message for a “warning”, similar to on_success/failure_callback? I have a dag that will keep on running even if there are missing records for a date. I don’t want it to fail, but I would like to get notified when a missing record is found, without having to stop the dag.
Is there any way of making a “pinpoint-warning” for the dag to “pick-up”/report? Or do I have to rearrange the dag so a separate task checks if there are any warnings and go from there?
I tried to formulate my question in an understandable manner, I hope it’s not too unclear.