tvalentyn commented on issue #28399:
URL: https://github.com/apache/beam/issues/28399#issuecomment-1721664056
Repro:
```
import argparse
import logging
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
from apache_beam.runners import DataflowRunner
from apache_beam.runners.interactive.interactive_runner import
InteractiveRunner
def run(argv=None):
parser = argparse.ArgumentParser()
options = PipelineOptions()
p = beam.Pipeline(InteractiveRunner())
p | beam.Create([1])
beam.runners.DataflowRunner().run_pipeline(p,
options=options).wait_until_finish()
if __name__ == '__main__':
logging.getLogger().setLevel(logging.INFO)
run()
```
```
python pipeline.py --project google.com:clouddfe
--temp_location=gs://clouddfe-valentyn
--staging_location=gs://clouddfe-valentyn --region us-central1
```
fails with
ERROR:apache_beam.runners.dataflow.dataflow_runner:2023-09-15T18:10:32.288Z:
JOB_MESSAGE_ERROR: Runnable workflow has no steps specified.
INFO:apache_beam.runners.dataflow.dataflow_runner:Job
2023-09-15_11_10_28-12637281573769828865 is in state JOB_STATE_FAILED
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
