Mycchaka Kleinbort
06/07/2023, 2:58 PM@asset
def latest_data()->pd.DataFrame:
...
return df
@asset
def send_email_if_latest_data_is_empty(latest_data)->None:
if latest_data.is_empty:
send_warning_email()
Is there a better way to handle this? In particular I really like seeing these dependencies in the Dagit UIsandy
06/07/2023, 3:24 PMMycchaka Kleinbort
06/07/2023, 3:29 PM