(self, session_id: str)
| 6289 | "SELECT metadata FROM delegation_runs WHERE run_id = ? AND project_id = ?", |
| 6290 | (context.run_id, context.project_id), |
| 6291 | ) as cursor: |
| 6292 | run_row = await cursor.fetchone() |
| 6293 | if run_row is None: |
| 6294 | return False |
| 6295 | durable_origins.append( |
| 6296 | _json_loads(run_row[0], {}).get("origin_owner_interaction") |
| 6297 | ) |
| 6298 | async with db.execute( |
| 6299 | """SELECT metadata FROM delegation_work_items |
| 6300 | WHERE work_item_id = ? AND run_id = ?""", |
| 6301 | (context.work_item_id, context.run_id), |
| 6302 | ) as cursor: |
| 6303 | work_item_row = await cursor.fetchone() |
| 6304 | if work_item_row is None: |
| 6305 | return False |
| 6306 | durable_origins.append( |
no test coverage detected