skip indexing retry fx

Author: hallvictoria

workers/tests/emulator_tests/eventhub_functions/eventhub_retry_stein/function_app.py

@@ -21,50 +21,50 @@ def eventhub_retry_output(req: func.HttpRequest, event: func.Out[str]):
 
 
 # EventHub trigger with exponential backoff retry policy (no explicit intervals)
-@app.function_name(name="eventhub_retry_trigger")
-@app.retry(
-    strategy="exponential_backoff",
-    max_retry_count="3"
-    # Note: minimum_interval and maximum_interval are optional
-    # and will use default values if not specified
-)
-@app.event_hub_message_trigger(
-    arg_name="event",
-    event_hub_name="python-worker-ci-eventhub-retry",
-    connection="AzureWebJobsEventHubConnectionString"
-)
-@app.blob_output(arg_name="$return",
-                 path="python-worker-tests/test-eventhub-retry-triggered.txt",
-                 connection="AzureWebJobsStorage")
-def eventhub_retry_trigger(event: func.EventHubEvent, context: func.Context) -> bytes:
-    event_id = event.get_body().decode('utf-8')
-    retry_count = context.retry_context.retry_count if context.retry_context else 0
-    max_retry = context.retry_context.max_retry_count if context.retry_context else 0
+# @app.function_name(name="eventhub_retry_trigger")
+# @app.retry(
+#     strategy="exponential_backoff",
+#     max_retry_count="3"
+#     # Note: minimum_interval and maximum_interval are optional
+#     # and will use default values if not specified
+# )
+# @app.event_hub_message_trigger(
+#     arg_name="event",
+#     event_hub_name="python-worker-ci-eventhub-retry",
+#     connection="AzureWebJobsEventHubConnectionString"
+# )
+# @app.blob_output(arg_name="$return",
+#                  path="python-worker-tests/test-eventhub-retry-triggered.txt",
+#                  connection="AzureWebJobsStorage")
+# def eventhub_retry_trigger(event: func.EventHubEvent, context: func.Context) -> bytes:
+#     event_id = event.get_body().decode('utf-8')
+#     retry_count = context.retry_context.retry_count if context.retry_context else 0
+#     max_retry = context.retry_context.max_retry_count if context.retry_context else 0
 
-    logging.info(f'EventHub retry trigger processed event: {event_id}, '
-                 f'retry count: {retry_count}, max retry: {max_retry}')
+#     logging.info(f'EventHub retry trigger processed event: {event_id}, '
+#                  f'retry count: {retry_count}, max retry: {max_retry}')
 
-    # Track retry attempts
-    if event_id not in retry_attempts:
-        retry_attempts[event_id] = []
-    retry_attempts[event_id].append(retry_count)
+#     # Track retry attempts
+#     if event_id not in retry_attempts:
+#         retry_attempts[event_id] = []
+#     retry_attempts[event_id].append(retry_count)
 
-    # Create result dictionary
-    result = {
-        'event_id': event_id,
-        'retry_count': retry_count,
-        'max_retry_count': max_retry,
-        'all_attempts': retry_attempts[event_id]
-    }
+#     # Create result dictionary
+#     result = {
+#         'event_id': event_id,
+#         'retry_count': retry_count,
+#         'max_retry_count': max_retry,
+#         'all_attempts': retry_attempts[event_id]
+#     }
 
-    # Fail on first two attempts to test retry
-    if retry_count < 2:
-        logging.warning(f'Simulating failure for retry test (attempt {retry_count})')
-        raise Exception(f"Simulated failure for retry testing (attempt {retry_count})")
+#     # Fail on first two attempts to test retry
+#     if retry_count < 2:
+#         logging.warning(f'Simulating failure for retry test (attempt {retry_count})')
+#         raise Exception(f"Simulated failure for retry testing (attempt {retry_count})")
 
-    # Success on third attempt
-    logging.info(f'Success on attempt {retry_count}')
-    return json.dumps(result).encode('utf-8')
+#     # Success on third attempt
+#     logging.info(f'Success on attempt {retry_count}')
+#     return json.dumps(result).encode('utf-8')
 
 
 # Retrieve the event data from storage blob and return it as Http response