parade.notify package

Submodules

parade.notify.default module

Module contents

class parade.notify.Notifier

Bases: parade.core.Plugin

The notifier to notify task event (success/fail)

notify_error(task, reason, **kwargs)

unschedule the task-flow :param flow_name: the flow name :return:

notify_success(task, **kwargs)

schedule the task-flow :param dag_key: the flow name :param cron: the cron string to schedule the flow :return: