BhuviTheDataGuy commented on issue #11551:
URL: https://github.com/apache/airflow/issues/11551#issuecomment-710770442
Im able to modify the original operator and there is a conversion function
that is doing this EPOCH conversion. So I customized it and everything looks
good now.
```py
def convert_type(self, value, schema_type):
"""
Takes a value from Postgres, and converts it to a value that's safe
for
JSON/Google Cloud Storage/BigQuery. Dates are converted to UTC
seconds.
Decimals are converted to floats. Times are converted to seconds.
"""
if isinstance(value, (datetime.datetime, datetime.date)):
return str(value)
if isinstance(value, datetime.time):
return str(value)
if isinstance(value, Decimal):
return float(value)
return value
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
