Anand Inguva

Merging this. Thanks.

@Polber is this PR still relevant?

Run Python 3.10 PostCommit

Run Python 3.8 PostCommit

Run Python 3.10 PostCommit

Run Python 3.8 PostCommit

Run Python 3.10 PostCommit

https://github.com/apache/beam/actions/runs/7191759283/job/19604271438 - successful run. MLTransform - https://pantheon.corp.google.com/dataflow/jobs/us-central1/2023-12-13_07_32_17-4151282941601198289;step=ref_AppliedPTransform_Map-lambda-at-criteo-py-98-_11;graphView=0?project=apache-beam-testing&pageState=(%22dfTime%22:(%22l%22:%22dfJobMaxTime%22))&e=13802955&mods=-ai_platform_fake_service,ai_platform_staging_service TFT - https://pantheon.corp.google.com/dataflow/jobs/us-central1/2023-12-12_23_03_42-286055797994519897;step=DecodeForTransform%2FRawRecordBeamSource;mainTab=JOB_GRAPH;graphView=0?project=apache-beam-testing&pageState=(%22dfTime%22:(%22l%22:%22dfJobMaxTime%22))&e=13802955&mods=-ai_platform_fake_service,ai_platform_staging_service Both are not apples to apples comparison but we can gain some insights and any potential improvements. I will see...

Seems like there is a spike - 

The pydocs are getting this error `04:42:45 WARNING:apache_beam.transforms.core:('No iterator is returned by the process method in %s.', ) for this DoFn. `https://github.com/apache/beam/blob/e26735d69f0935c6f7ac14dd0fb0e58ff390392a/sdks/python/apache_beam/transforms/core.py#L3519 Can you check it why since the DoFn...