Jakub Zgrzebnicki
06/15/2022, 5:52 AMJakub Zgrzebnicki
06/15/2022, 5:55 AMslack_resource
using a helper function ResourceDefinition.hardcoded_resource()
, so it won't send slack messages during development.
@graph
def slack_notif_all():
a()
b()
notif_all_prod = slack_notif_all.to_job(
name="notif_all_prod",
resource_defs={
"slack": ResourceDefinition.hardcoded_resource(
slack_resource_mock, "do not send messages in dev"
)
},
hooks={slack_message_on_failure},
)
notif_all_dev = slack_notif_all.to_job(
name="notif_all_dev",
resource_defs={"slack": slack_resource},
hooks={slack_message_on_failure},
)
Jakub Zgrzebnicki
06/15/2022, 5:56 AMrex
06/15/2022, 6:14 AMJakub Zgrzebnicki
06/15/2022, 6:19 AMif __name__ == "__main__":
with open(
file_relative_path(__file__, "prod_op_hooks.yaml"),
"r",
encoding="utf8",
) as fd:
run_config = yaml.safe_load(fd.read())
result = notif_all_dev.execute_in_process(
run_config=run_config, raise_on_error=False
)
shouldn't be notif_all_prod instead of notif_all_dev after your changes?