VladaZakharova commented on PR #54574:
URL: https://github.com/apache/airflow/pull/54574#issuecomment-3209767480
I was creating connection using:
```
AIRFLOW_CONN_GOOGLE_CLOUD_DEFAULT='{"conn_type": "google_cloud_default",
"extra": {"key_path": "/files/airflow-breeze-config/keys/keys.json", "scope":
"https://www.googleapis.com/auth/cloud-platform";, "project": "project_id",
"num_retries": 5}}'
```
the problem was originally with some of the triggered where we couldn't pass
Enum values from tigggerer to worker (also needs to be reworked).
Now after this mask changes the problem is with creating the connection
because of the changes made here https://github.com/apache/airflow/pull/51699 :
```
def _msgpack_enc_hook(obj: Any) -> Any:
import pendulum
if isinstance(obj, pendulum.DateTime):
# convert the pendulm Datetime subclass into a raw datetime so that
msgspec can use it's native
# encoding
return datetime(
obj.year, obj.month, obj.day, obj.hour, obj.minute, obj.second,
obj.microsecond, tzinfo=obj.tzinfo
)
if isinstance(obj, Path):
return str(obj)
if isinstance(obj, BaseModel):
return obj.model_dump(exclude_unset=True)
# Raise a NotImplementedError for other types
raise NotImplementedError(f"Objects of type {type(obj)} are not
supported")
```
We need I think more types here to support and it will solve the problem for
everyone.
--
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]
