jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

fix: fixes date time issue, which was blocking run flow execution of agent flows (#5866)

Browse source 
* fixes PydanticSerializationError

fixes:
    PydanticSerializationError: Error calling function `serialize_model`: TypeError: tz_convert() takes exactly 2 positional arguments (1 given)

* format

* [autofix.ci] apply automated fixes

* Update src/backend/base/langflow/api/v1/schemas.py

Co-authored-by: Gabriel Luiz Freitas Almeida <gabriel@langflow.org>

---------

Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
Co-authored-by: Gabriel Luiz Freitas Almeida <gabriel@langflow.org>
This commit is contained in:
Edwin Jose 2025-01-22 14:56:20 -05:00 • committed by GitHub
commit 8108d6fc13
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/backend/base/langflow/api/v1/schemas.py
View file

@ -287,7 +287,7 @@ class ResultDataResponse(BaseModel):
return f"{obj[:max_length]}... [truncated]" return f"{obj[:max_length]}... [truncated]"
return obj return obj
if isinstance(obj, datetime): if isinstance(obj, datetime):
return obj.astimezone().isoformat() return obj.replace(tzinfo=timezone.utc).isoformat()
if isinstance(obj, Decimal): if isinstance(obj, Decimal):
return float(obj) return float(obj)
if isinstance(obj, UUID): if isinstance(obj, UUID):

11
src/backend/base/langflow/graph/utils.py
View file

@ -86,6 +86,9 @@ def serialize_field(value):
if hasattr(value, "to_json"): if hasattr(value, "to_json"):
return value.to_json() return value.to_json()
return value.dict() return value.dict()
# Handle datetime objects
if hasattr(value, "isoformat"):
return value.isoformat()
return str(value) return str(value)
@ -182,10 +185,10 @@ async def log_vertex_build(
id=vertex_id, id=vertex_id,
valid=valid, valid=valid,
params=str(params) if params else None, params=str(params) if params else None,
# ugly hack to get the model dump with weird datatypes # Serialize data using our custom serializer
data=json.loads(data.model_dump_json()), data=serialize_field(data),
# ugly hack to get the model dump with weird datatypes # Serialize artifacts using our custom serializer
artifacts=json.loads(json.dumps(artifacts, default=str)), artifacts=serialize_field(artifacts) if artifacts else None,
) )
async with session_getter(get_db_service()) as session: async with session_getter(get_db_service()) as session:
inserted = await crud_log_vertex_build(session, vertex_build) inserted = await crud_log_vertex_build(session, vertex_build)