Skip to content

MetricsDefault

dotflow.providers.metrics_default.MetricsDefault

Bases: Metrics

Source code in dotflow/providers/metrics_default.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
class MetricsDefault(Metrics):
    def workflow_started(self, workflow_id: Any, **kwargs) -> None:
        pass

    def workflow_completed(self, workflow_id: Any, duration: float) -> None:
        pass

    def workflow_failed(self, workflow_id: Any, duration: float) -> None:
        pass

    def task_completed(self, task: Any) -> None:
        pass

    def task_failed(self, task: Any) -> None:
        pass

    def task_retried(self, task: Any) -> None:
        pass

task_completed(task)

Source code in dotflow/providers/metrics_default.py 
18
19
def task_completed(self, task: Any) -> None:
    pass

task_failed(task)

Source code in dotflow/providers/metrics_default.py 
21
22
def task_failed(self, task: Any) -> None:
    pass

task_retried(task)

Source code in dotflow/providers/metrics_default.py 
24
25
def task_retried(self, task: Any) -> None:
    pass

workflow_completed(workflow_id, duration)

Source code in dotflow/providers/metrics_default.py 
12
13
def workflow_completed(self, workflow_id: Any, duration: float) -> None:
    pass

workflow_failed(workflow_id, duration)

Source code in dotflow/providers/metrics_default.py 
15
16
def workflow_failed(self, workflow_id: Any, duration: float) -> None:
    pass

workflow_started(workflow_id, **kwargs)

Source code in dotflow/providers/metrics_default.py 
 9
10
def workflow_started(self, workflow_id: Any, **kwargs) -> None:
    pass