Abstract

flowtask.tasks.abstract

AbstractTask

AbstractTask(task_id=None, task=None, program=None, loop=None, parser=None, userid=None, **kwargs)

Bases: ABC

AbstractTask.

Base class for all Dataintegration tasks.

stats property

stats

stats. Return a TaskMonitor object with all collected stats. Returns: TaskMonitor: stat object.

__aenter__ async

__aenter__()

Magic Context Methods

check_syntax

check_syntax(task)

check_syntax.

Validates the syntax of a JSON task based on a predefined schema. Ensures that the task has all required fields and correct data structures.

Parameters:

task : dict The task definition to validate.

Returns:

bool Returns True if the task is valid; raises TaskParseError otherwise.

Raises:

TaskParseError If the task does not conform to the expected schema, an error is raised with details about what failed.

task_events

task_events()

Initialize Event manager with a default list of events.