flytekit.core.notification
Notifications are primarily used when defining Launch Plans (also can be used when launching executions) and will trigger the Flyte platform to send emails when a workflow run reaches certain stages (fails or succeeds, etc.).
Each notification type takes a list of flytekit.models.core.execution.WorkflowExecutionPhase and a list of
emails. Even though there are different notification classes in this module, they all just send email. The differentiation
offers semantic meaning to the end-user but do not functionally behave differently. Successful integration with Slack
and Pagerduty is incumbent on those email API being set-up correctly.
Directory
Classes
| Class | Description |
|---|---|
Email |
This notification should be used when sending regular emails to people. |
Notification |
|
PagerDuty |
This notification should be used when sending emails to the PagerDuty service. |
Slack |
This notification should be used when sending emails to the Slack. |
flytekit.core.notification.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
class Email(
phases: typing.List[int],
recipients_email: typing.List[str],
)| Parameter | Type | Description |
|---|---|---|
phases |
typing.List[int] |
|
recipients_email |
typing.List[str] |
Properties
| Property | Type | Description |
|---|---|---|
email |
None |
|
is_empty |
None |
|
pager_duty |
None |
|
phases |
None |
A list of phases to which users can associate the notifications. |
slack |
None |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
Returns: Notification
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: flyteidl.admin.common_pb2.Notification
flytekit.core.notification.Notification
Parameters
class Notification(
phases: typing.List[int],
email: flytekit.models.common.EmailNotification,
pager_duty: flytekit.models.common.PagerDutyNotification,
slack: flytekit.models.common.SlackNotification,
)| Parameter | Type | Description |
|---|---|---|
phases |
typing.List[int] |
|
email |
flytekit.models.common.EmailNotification |
|
pager_duty |
flytekit.models.common.PagerDutyNotification |
|
slack |
flytekit.models.common.SlackNotification |
Properties
| Property | Type | Description |
|---|---|---|
email |
None |
|
is_empty |
None |
|
pager_duty |
None |
|
phases |
None |
A list of phases to which users can associate the notifications. |
slack |
None |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
Returns: Notification
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: flyteidl.admin.common_pb2.Notification
flytekit.core.notification.PagerDuty
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
class PagerDuty(
phases: typing.List[int],
recipients_email: typing.List[str],
)| Parameter | Type | Description |
|---|---|---|
phases |
typing.List[int] |
|
recipients_email |
typing.List[str] |
Properties
| Property | Type | Description |
|---|---|---|
email |
None |
|
is_empty |
None |
|
pager_duty |
None |
|
phases |
None |
A list of phases to which users can associate the notifications. |
slack |
None |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
Returns: Notification
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: flyteidl.admin.common_pb2.Notification
flytekit.core.notification.Slack
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
class Slack(
phases: typing.List[int],
recipients_email: typing.List[str],
)| Parameter | Type | Description |
|---|---|---|
phases |
typing.List[int] |
|
recipients_email |
typing.List[str] |
Properties
| Property | Type | Description |
|---|---|---|
email |
None |
|
is_empty |
None |
|
pager_duty |
None |
|
phases |
None |
A list of phases to which users can associate the notifications. |
slack |
None |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
Returns: Notification
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: flyteidl.admin.common_pb2.Notification