etl_lib.task.ExecuteCypherTask module

class ExecuteCypherTask(context)

Bases: Task

Execute cypher (write) as a Task.

This task is for data refinement jobs, as it does not return cypher results. Parameters can be passed as keyword arguments to the constructor and will be available as parameters inside cypher.

Parameters:

context (ETLContext)

__init__(context)

Construct a Task object.

Parameters:

context (ETLContext) – ETLContext instance. Will be available to subclasses.

run_internal(**kwargs)

Place to provide the logic to be performed.

This base class provides all the housekeeping and reporting, so that implementation must/should not need to care about them. Exceptions should not be captured by implementations. They are handled by this base class.

Parameters:

kwargs – will be passed to run_internal

Return type:

TaskReturn

Returns:

An instance of TaskReturn.