René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"`retry` parameter ignored in the `operation.result(retry=retry)` call","articleBody":"#### Environment details\r\n\r\n  - OS type and version: `Debian 5.18.16`\r\n  - Python version: `Python 3.10.7`\r\n  - pip version: `pip 22.0.2 from /usr/lib/python3/dist-packages/pip (python 3.10)`\r\n  - google-api-core version: `2.10.1`\r\n\r\n#### Steps to reproduce\r\n\r\n  1.  Use any GCP API that returns LRO\r\n  2. Use `operation.result` method call with custom `retry` parameter\r\n  3. This method will return ~60 seconds after actual operation finishes, while it should not have more than 10 seconds of overhead with custom retry policy (see below)\r\n\r\n#### Code example\r\n\r\n```python\r\nfrom google.api_core import retry\r\nfrom google.cloud import dataproc_v1\r\nfrom google.api_core.client_options import ClientOptions\r\n\r\nimport time\r\n\r\nproject = '. . .'\r\nregion = 'us-central1'\r\n\r\n# Create Dataproc batch\r\nclient_options = ClientOptions(api_endpoint=\"{}-dataproc.googleapis.com:443\".format(region))\r\nclient = dataproc_v1.BatchControllerClient(client_options=client_options)\r\nbatch = dataproc_v1.Batch()\r\nbatch.spark_batch.main_class = 'org.apache.spark.examples.SparkPi'\r\nbatch.spark_batch.jar_file_uris = [\r\n  'file:///usr/lib/spark/examples/jars/spark-examples.jar',\r\n]\r\nbatch.spark_batch.args = ['1']\r\nbatch.runtime_config.properties = {\r\n  'spark.executor.instances': '2',\r\n}\r\n\r\nparent = f\"projects/{project}/locations/{region}\"\r\nrequest = dataproc_v1.CreateBatchRequest(\r\n  parent=parent,  # type: ignore\r\n  batch=batch,  # type: ignore\r\n)\r\n\r\n# Make the request\r\nprint(\"Creating batch\")\r\noperation = client.create_batch(request=request)  # type: ignore\r\nprint(\"Batch created\")\r\n\r\n# This takes quite a while, waiting on GCP response to resolve\r\nretry = retry.Retry(initial=10, maximum=10, multiplier=1.0, deadline=600)\r\nstart = time.time()\r\nresponse = operation.result(retry=retry)\r\nprint(\"Batch finished\")\r\nprint(f\"Took {time.time() - start} seconds to finish batch job\")\r\nprint(response)\r\n```\r\n\r\nAfter replacing `response = operation.result(retry=retry)` call with custom wait/retry logic operation completion will be detected as expected:\r\n\r\n```python\r\nwhile not operation.done(retry=None):\r\n  time.sleep(10)\r\nresponse = operation.metadata\r\n```","author":{"url":"https://github.com/medb","@type":"Person","name":"medb"},"datePublished":"2022-10-04T03:35:33.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":5},"url":"https://github.com/458/python-api-core/issues/458"}