Source code for lories.connectors.tasks.write

# -*- coding: utf-8 -*-
"""
lories.connectors.tasks.write
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~


"""

from lories._core._channels import Channels  # noqa
from lories.connectors.tasks.task import ConnectorTask




class WriteTask(ConnectorTask):


    def run(self) -> None:
        self._logger.debug(
            f"Writing {len(self.channels)} channels of '{type(self.connector).__name__}': {self.connector.id}"
        )
        self._run_write(self.channels)


    def _run_write(self, channels: Channels) -> None:
        self.connector.write(channels.to_frame(unique=True))