Hello,

I would like to access the graph object of my Apache Beam pipeline to traverse 
it myself and also print it locally before running. I thought I could find the 
starting point of my DAG from the pipeline or runner instantiation 
(https://github.com/apache/beam/blob/master/sdks/python/apache_beam/pipeline.py#L20).

Do you know if there is an attribute or method I could call from the pipeline 
to get the graph ?

I am using “apache-beam[gcp]==2.11.0” with a DirectRunner and DataflowRunner.

Regards,

Germain T.

Reply via email to