Notifications#

class flytekit.Email(phases, recipients_email)#

This notification should be used when sending regular emails to people.

from flytekit.models.core.execution import WorkflowExecutionPhase

Email(phases=[WorkflowExecutionPhase.SUCCEEDED], recipients_email=["[email protected]"])
Parameters:

  • phases (List[int])

  • recipients_email (List[str])

class flytekit.PagerDuty(phases, recipients_email)#

This notification should be used when sending emails to the PagerDuty service.

from flytekit.models.core.execution import WorkflowExecutionPhase

PagerDuty(phases=[WorkflowExecutionPhase.SUCCEEDED], recipients_email=["[email protected]"])
Parameters:

  • phases (List[int])

  • recipients_email (List[str])

class flytekit.Slack(phases, recipients_email)#

This notification should be used when sending emails to the Slack.

from flytekit.models.core.execution import WorkflowExecutionPhase

Slack(phases=[WorkflowExecutionPhase.SUCCEEDED], recipients_email=["[email protected]"])
Parameters:

  • phases (List[int])

  • recipients_email (List[str])