Method process

backend/python/pydevlake/pydevlake/subtasks.py:110–114

Called for all data entries returned by `fetch`.

(self, data: object, session: Session, ctx: Context)

    @abstractmethod
    def process(self, data: object, session: Session, ctx: Context):
        """
        Called for all data entries returned by `fetch`.
        """
        pass

    def _get_last_state(self, session, connection_id):
        stmt = (