def visit_value(self, value, producer_node):
    pass
Callback for visiting a PValue in the pipeline DAG.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/pipeline.py/PipelineVisitor.visit_value