Method fetch

backend/python/pydevlake/pydevlake/subtasks.py:142–143

(self, state: Dict, _, ctx: Context)

        return 'collect'

    def fetch(self, state: Dict, _, ctx: Context) -> Iterable[Tuple[object, Dict]]:
        return self.stream.collect(state, ctx)

    def process(self, data: object, session: Session, ctx: Context):
        raw_model_class = self.stream.raw_model(session)