Skip to content

Runner

flowtask.runner

DataIntegration Task Runner.

This Module can run data-integration tasks, HTTP/RESTful calls (or even any arbitrary python function), received parametriced tasks and return the results.

Task Runner receives different command-line arguments:

--variables: override variables passed between components/processes. --attributes: override root-level attributes of components. --conditions: override values in components with conditions. --params: any value in params ins passed as kwargs --args: list of arguments to be used by some functions (like replacement of values)

  • For Calling a task: --program=program_name --task=task_name --params
  • For calling Python Functions: --function=path.to.python.import --params
  • System Command: --command=path.to.command --params
  • or even Calling a URL: --url=URI --params

TaskRunner 

TaskRunner(loop=None, worker=None, **kwargs)

TaskRunner.

Execution of DataIntegration Tasks.

stats property 

stats

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

__aenter__ async 

__aenter__()

Magic Context Methods

__aexit__ async 

__aexit__(exc_type, exc_val, exc_tb)

Magic Context Methods