potiuk commented on code in PR #44330:
URL: https://github.com/apache/airflow/pull/44330#discussion_r1863150559
##########
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:
Did not we already drop it and switched to fast_api ?
--
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]
