Output Modules

Output modules are primarily used to store or send data to third-party systems. Output modules therefore do not have an output port - only an input port for receiving data.

Example
from modules.base.outputs.base import AbstractOutputModule, models

class OutputModule(AbstractOutputModule):
    ...

    def __init__(self, configuration: Configuration):
        super().__init__(configuration=configuration)

    def _run(self, data: models.Data):
        """
        This method is called when new data needs to be processed.
        :param data: The data object to be processed.
        """
        self.logger.info(data)
Info
The _run method is called by a single thread and is therefore thread-safe.