luna_lambda_tools.public.tasks.BaseLambdaTask

class luna_lambda_tools.public.tasks.BaseLambdaTask(*args, **kwargs)[source]

Lambda task

__init__(*args, **kwargs)[source]

Methods

__init__(*args, **kwargs)

createErrors(taskId, subTaskId, taskType, ...)

createSubTaskError(subTaskError)

Create sub task error

exceptionHandler(asyncRunner_, context)

Handle exceptions.

execute(taskData)

Execute current sub task processing

executeSubtask(subTaskContent)

Execute current sub task processing

flushExecutionMonitoringData(taskData[, ...])

Flush a data about an execution subtask to the monitoring.

getKwargsFromTaskData(taskData)

Get kwargs from task data

initFromConfig(influxMonitoring, ...)

Init from config.

onShutDown()

Perform shutdown actions

saveResultToImageStore(result, taskData[, ...])

Save a task result to image store

sendToMonitoring(points)

Send point to monitoring

separationStart([lambdaId])

Start separation processing

splitTask2SubTasks(taskContentRequest)

Split task content to sub task contents

splitTasksContent(content)

Split task content to sub task contents

start([lambdaId])

Start task processing

Attributes

clients

taskType

Task type

accountId

app