[image: :wave:] Newb here for what will certainly be the first of many
silly questions ...

I'm working on a dataflow pipeline using python SDK (local runners
currently).

It's a bounded source from BigQuery. One column is a TIMESTAMP. I'm trying
to assign the timestamp using beam.window.TimestampedValue() but the
timestamp I'm getting back from BQ seems to be a string and not in RFC3339
format.

The format is '2019-12-13 09:38:19.380224 UTC' ... which I could explicitly
convert but I'd rather do that in the query.

Any suggestions on how to get the timestamp back in format I can parse with
iso8601.parse_date() or, ideally, just pass into TimestampedValue() without
having to parse a string?

Thanks

Reply via email to