AFL.double_agent.PipelineOp module#

class AFL.double_agent.PipelineOp.PipelineOp(name: str | None | List[str] = None, input_variable: str | None | List[str] = None, output_variable: str | None | List[str] = None, input_prefix: str | None | List[str] = None, output_prefix: str | None | List[str] = None)#

Bases: ABC

Abstract base class for data processors. All operations in AFL.double_agent should inherit PipelineOpBase.

Parameters:

  • name (Optional[str] | List[str]) – The name to use when added to a Pipeline. This name is used when calling Pipeline.search()

  • input_variable (Optional[str] | List[str]) – The name of the xarray.Dataset data variable to extract from the input dataset

  • output_variable (Optional[str] | List[str]) – The name of the variable to be inserted into the xarray.Dataset by this PipelineOp

  • input_prefix (Optional[str] | List[str]) – Prefix for input variables when using pattern matching

  • output_prefix (Optional[str] | List[str]) – Prefix for output variables when using pattern matching

add_to_dataset(dataset, copy_dataset=True)#

Adds (xarray) data in output dictionary to provided xarray dataset

add_to_tiled(tiled_data)#

Adds data in output dictionary to provided tiled catalogue

abstract calculate(dataset: Dataset) → Self#
copy() → Self#
classmethod from_json(json_data)#

Deserializes the JSON string back to an object. Dynamically imports the module, gets the class, and instantiates it using the stored constructor arguments.

plot(**mpl_kwargs) → Figure#
to_json()#

Serializes the fully qualified class name and the constructor arguments stored in _stored_args into a JSON string.