kiran
@channel
@here
SlackTask
<@channel>
... elif new_state.is_failed(): data_engineer_user_id = Secret("DATA_ENGINEER_USER_ID").get() msg = f"<@{data_engineer_user_id}> — {obj} ({flow_run_name}): {new_state}" SlackTask(message=msg, webhook_secret="SLACK_WEBHOOK_URL").run()
Kevin Kho
<!channel>
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.