I am using beam just to read data from pubsub and doing some
transformation and loading the data into bigquery. When I am running my
code using colob my code is runnign fine but when i am using dataflow as
runner i am getting error like 'PicklingErro...