| 143 | return self.stream.collect(state, ctx) |
| 144 | |
| 145 | def process(self, data: object, session: Session, ctx: Context): |
| 146 | raw_model_class = self.stream.raw_model(session) |
| 147 | url, input_info = "", "" |
| 148 | if "x_request_url" in data: |
| 149 | url = data["x_request_url"] |
| 150 | del data["x_request_url"] |
| 151 | if "x_request_input" in data: |
| 152 | input_info = data["x_request_input"] |
| 153 | del data["x_request_input"] |
| 154 | raw_model = raw_model_class( |
| 155 | params=self._params(ctx), |
| 156 | data=json.dumps(data).encode('utf8'), |
| 157 | url=url, |
| 158 | input=json.dumps(input_info).encode('utf8'), |
| 159 | ) |
| 160 | session.add(raw_model) |
| 161 | |
| 162 | def delete(self, session, ctx): |
| 163 | raw_model = self.stream.raw_model(session) |