pi_portal.modules.tasks.processor.camera_snapshot.ProcessorClass

class pi_portal.modules.tasks.processor.camera_snapshot.ProcessorClass(*args: Any, **kwargs: Any)[source]

Bases: CameraClientMixin, TaskProcessorBase[Args, None]

Processes requests to take a snapshot with a camera.

__init__(*args: Any, **kwargs: Any) → None
log_timings(processing_start_time: datetime, task: TaskBase[TypeTaskArguments_co, TypeTaskResult]) → None

Log a task’s timing data with respect to it’s processing start time.

Parameters:

  • processing_start_time (datetime) – The time at which processing began.

  • task (TaskBase[TypeTaskArguments_co, TypeTaskResult]) – The task to log timing data for.

process(task: TaskBase[TypeTaskArguments_co, TypeTaskResult]) → None

Invoke the task capturing any thrown exception internally.

Parameters:

task (TaskBase[TypeTaskArguments_co, TypeTaskResult]) – The task to process.

recover(task: TaskBase[TypeTaskArguments_co, TypeTaskResult]) → None

Log a message to indicate this partially failed task is recovered.

Parameters:

task (TaskBase[TypeTaskArguments_co, TypeTaskResult]) – The task to process.