批量更新任务 多处调用,更新的字段必须一致 注意:需要 写成 yield update_task_batch(...) 否则不会更新 @param task_id: @param state: @param kwargs: @return:
(self, task_id, state=1, **kwargs)
| 173 | update_task = update_task_state |
| 174 | |
| 175 | def update_task_batch(self, task_id, state=1, **kwargs): |
| 176 | """ |
| 177 | 批量更新任务 多处调用,更新的字段必须一致 |
| 178 | 注意:需要 写成 yield update_task_batch(...) 否则不会更新 |
| 179 | @param task_id: |
| 180 | @param state: |
| 181 | @param kwargs: |
| 182 | @return: |
| 183 | """ |
| 184 | kwargs["id"] = task_id |
| 185 | kwargs[self._task_state] = state |
| 186 | |
| 187 | update_item = UpdateItem(**kwargs) |
| 188 | update_item.table_name = self._task_table |
| 189 | update_item.name_underline = self._task_table + "_item" |
| 190 | |
| 191 | return update_item |
| 192 | |
| 193 | |
| 194 | class BatchParser(TaskParser): |