| 206 | |
| 207 | |
| 208 | class SubtaskRun(SQLModel, table=True): |
| 209 | __tablename__ = '_pydevlake_subtask_runs' |
| 210 | """ |
| 211 | Table storing information about the execution of subtasks. |
| 212 | """ |
| 213 | id: Optional[int] = Field(primary_key=True) |
| 214 | subtask_name: str |
| 215 | connection_id: int |
| 216 | started: datetime |
| 217 | completed: Optional[datetime] |
| 218 | state: str = Field(sa_column=Column(Text)) # JSON encoded dict of atomic values |