kaxil commented on code in PR #44330:
URL: https://github.com/apache/airflow/pull/44330#discussion_r1862839928
##########
providers/src/airflow/providers/edge/worker_api/datamodels.py:
##########
@@ -67,3 +82,10 @@ class WorkerQueueUpdateBody(BaseModel):
remove_queues: Optional[List[str]] = Field( # noqa: UP006, UP007 -
prevent pytest failing in back-compat
description="Queues to remove from worker."
)
+
+
+class PushLogsBody(BaseModel):
+ """Incremental new log content from worker."""
+
+ log_chunk_time: datetime = Field(description="Time of the log chunk at
point of sending.")
+ log_chunk_data: str = Field(description="Log chunk data as incremental log
text.")
Review Comment:
Same as "Part1" PR -- you can move this to `Annotated` and make metadata
part of typehints instead
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
