kaxil commented on code in PR #74729: URL: https://github.com/apache/airflow/pull/74729#discussion_r4339928561
########## providers/common/ai/docs/structured_output.rst: ########## @@ -50,6 +50,34 @@ loaded Dag's tasks at startup and registers each declared class, so it also work for mapped producers (``.expand(...)``) and for workers that load Dags from a cache that bypasses operator construction. +The worker finds no class to register when ``output_type`` is a list of output +types such as ``[Summary, int]``, an output marker such as +``ToolOutput(Summary)``, an output function, a ``TypeAliasType`` or a +``NewType``. For these output types, ``AgentOperator`` and ``@task.agent`` push +each model in the output as a JSON-compatible dict, including models inside a +list, tuple or dict. A model is pushed as a dict even if its class is listed in +``[core] allowed_deserialization_classes``, or if another task in the same Dag +declares the class as its ``output_type``. A downstream task therefore reads +``result["field"]``, not ``result.field``. + +In a JSON-compatible dict, values such as ``datetime``, ``date``, ``UUID`` and +``Decimal`` arrive as strings, tuples and sets arrive as lists, and ``Enum`` +members arrive as their values. In HITL review, the released common.ai 1.0.0 +dumped a top-level model of these output types with plain ``model_dump()`` +after the reviewer approved the model. On Airflow 3.3 and later without +``serialize_output=True``, the ``datetime`` fields of such a model therefore +arrive as strings after an upgrade, not as ``datetime`` objects. Review Comment: Unless this makes it before 1.1.0 is released.. It is currently being voted on https://lists.apache.org/thread.html/sn28295qls3pk7lv5nx3smpgqtmz1m1g -- 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]
