increased time to cancel

Author: aIbrahiim

sdks/python/apache_beam/examples/inference/pytorch_sentiment.py

@@ -316,8 +316,12 @@ def run(
           method=method))
 
   result = pipeline.run()
+  # For streaming benchmarks, run for a bounded duration, then cancel and wait
+  # until terminal state so benchmark harness does not observe a lingering
+  # CANCELLING job.
   result.wait_until_finish(duration=1800000)  # 30 min
   result.cancel()
+  result.wait_until_finish(duration=600000)  # up to 10 min to settle cancel
 
   cleanup_pubsub_resources(
       project=known_args.project,