in services/ui_backend_service/data/db/models/task_row.py [0:0]
def serialize(self, expanded: bool = False):
if expanded:
return {
"flow_id": self.flow_id,
"run_number": self.run_number,
"run_id": self.run_id,
"step_name": self.step_name,
"task_id": self.task_id,
"task_name": self.task_name,
"user_name": self.user_name,
"status": self.status,
"task_ok": self.task_ok,
"ts_epoch": self.ts_epoch,
"started_at": self.started_at,
"finished_at": self.finished_at,
"duration": self.duration,
"attempt_id": self.attempt_id,
"tags": self.tags,
"system_tags": self.system_tags,
"last_heartbeat_ts": self.last_heartbeat_ts
}
else:
return {
"flow_id": self.flow_id,
"run_number": str(get_exposed_run_id(self.run_number, self.run_id)),
"step_name": self.step_name,
"task_id": str(get_exposed_task_id(self.task_id, self.task_name)),
"user_name": self.user_name,
"status": self.status,
"task_ok": self.task_ok,
"ts_epoch": self.ts_epoch,
"started_at": self.started_at,
"finished_at": self.finished_at,
"duration": self.duration,
"attempt_id": self.attempt_id,
"tags": self.tags,
"system_tags": self.system_tags,
"last_heartbeat_ts": self.last_heartbeat_ts
}