fix tests

Author: hallvictoria

.github/ISSUE_TEMPLATE/deferred_bindings_bug_report.yml

@@ -40,7 +40,7 @@ def eventhub_multiple(events) -> str:
                       connection="AzureWebJobsEventHubConnectionString",
                       event_hub_name="python-worker-ci-eventhub-batch")
 @app.route(route="eventhub_output_batch", binding_arg_name="out")
-def c(req: func.HttpRequest, out: func.Out[str]) -> str:
+def eventhub_output_batch(req: func.HttpRequest, out: func.Out[str]) -> str:
     events = req.get_body().decode('utf-8')
     return events
 

.github/ISSUE_TEMPLATE/deferred_bindings_feature_request.yml

@@ -45,65 +45,3 @@ def test_servicebus_multiple(self):
             row_keys_seen[row_key] = True
 
         self.assertDictEqual(all_row_keys_seen, row_keys_seen)
-
-    # @testutils.retryable_test(3, 5)
-    # def test_servicebus_multiple_with_metadata(self):
-    #     # Generate a unique event body for EventHub event
-    #     # Record the start_time and end_time for checking event enqueue time
-    #     start_time = datetime.utcnow()
-    #     count = 10
-    #     random_number = str(round(time.time()) % 1000)
-    #     req_body = {
-    #         'body': random_number
-    #     }
-
-    #     # Invoke metadata_output HttpTrigger to generate an EventHub event
-    #     # from azure-eventhub SDK
-    #     r = self.webhost.request('POST',
-    #                              f'metadata_output_batch?count={count}',
-    #                              data=json.dumps(req_body))
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertIn('OK', r.text)
-    #     end_time = datetime.utcnow()
-
-    #     # Once the event get generated, allow function host to pool from
-    #     # EventHub and wait for metadata_multiple to execute,
-    #     # converting the event metadata into a blob.
-    #     time.sleep(5)
-
-    #     # Call get_metadata_batch_triggered to retrieve event metadata
-    #     r = self.webhost.request('GET', 'get_metadata_batch_triggered')
-    #     self.assertEqual(r.status_code, 200)
-
-    #     # Check metadata and events length, events should be batched processed
-    #     events = r.json()
-    #     self.assertIsInstance(events, list)
-    #     self.assertGreater(len(events), 1)
-
-    #     # EventhubEvent property check
-    #     for event_index in range(len(events)):
-    #         event = events[event_index]
-
-    #         # Check if the event is enqueued between start_time and end_time
-    #         enqueued_time = parser.isoparse(event['enqueued_time'])
-    #         self.assertTrue(start_time < enqueued_time < end_time)
-
-    #         # Check if event properties are properly set
-    #         self.assertIsNone(event['partition_key'])  # only 1 partition
-    #         self.assertGreaterEqual(event['sequence_number'], 0)
-    #         self.assertIsNotNone(event['offset'])
-
-    #         # Check if event.metadata field is properly set
-    #         self.assertIsNotNone(event['metadata'])
-    #         metadata = event['metadata']
-    #         sys_props_array = metadata['SystemPropertiesArray']
-    #         sys_props = sys_props_array[event_index]
-    #         enqueued_time = parser.isoparse(sys_props['EnqueuedTimeUtc'])
-
-    #         # Check event trigger time and other system properties
-    #         self.assertTrue(
-    #             start_time.timestamp() < enqueued_time.timestamp()
-    #             < end_time.timestamp())  # NoQA
-    #         self.assertIsNone(sys_props['PartitionKey'])
-    #         self.assertGreaterEqual(sys_props['SequenceNumber'], 0)
-    #         self.assertIsNotNone(sys_props['Offset'])