Method process

backend/python/pydevlake/pydevlake/subtasks.py:187–192

(self, raw: RawModel, session: Session, ctx: Context)

            yield raw, state

    def process(self, raw: RawModel, session: Session, ctx: Context):
        tool_model = self.stream.extract(json.loads(raw.data))
        tool_model.set_raw_origin(raw)
        tool_model.connection_id = ctx.connection.id
        tool_model.set_updated_at()
        session.merge(tool_model)

    def delete(self, session, ctx):
        model = self.stream.tool_model