remove testqueue-batch + debugging e2e

Author: hallvictoria

workers/tests/emulator_tests/servicebus_batch_functions/servicebus_batch_functions_stein/function_app.py

@@ -9,7 +9,7 @@
 @app.service_bus_queue_output(
     arg_name="msg",
     connection="AzureWebJobsServiceBusConnectionString",
-    queue_name="testqueue-batch")
+    queue_name="testqueue")
 def servicebus_output_batch(req: func.HttpRequest, msg: func.Out[str]):
     msg.set(req.get_body().decode('utf-8'))
     return 'OK'
@@ -28,7 +28,7 @@ def get_servicebus_batch_triggered(req: func.HttpRequest,
 @app.service_bus_queue_trigger(
     arg_name="events",
     connection="AzureWebJobsServiceBusConnectionString",
-    queue_name="testqueue-batch",
+    queue_name="testqueue",
     cardinality="many")
 @app.blob_output(arg_name="$return",
                  path="python-worker-tests/test-servicebus-batch-triggered.txt",

workers/tests/emulator_tests/utils/servicebus/config.json

@@ -17,20 +17,6 @@
                "RequiresDuplicateDetection": false,
                "RequiresSession": false
              }
-           },
-           {
-             "Name": "testqueue-batch",
-             "Properties": {
-               "DeadLetteringOnMessageExpiration": false,
-               "DefaultMessageTimeToLive": "PT1H",
-               "DuplicateDetectionHistoryTimeWindow": "PT20S",
-               "ForwardDeadLetteredMessagesTo": "",
-               "ForwardTo": "",
-               "LockDuration": "PT1M",
-               "MaxDeliveryCount": 10,
-               "RequiresDuplicateDetection": false,
-               "RequiresSession": false
-             }
            }
          ]
        }

workers/tests/utils/testutils.py

@@ -159,7 +159,7 @@ def wrapper(self, *args, __meth__=test_case,
                             __check_log__=check_log_case, **kwargs):
                     if (__check_log__ is not None
                             and callable(__check_log__)
-                            and not is_envvar_true(PYAZURE_WEBHOST_DEBUG)):
+                            and not True):
 
                         # Check logging output for unit test scenarios
                         result = self._run_test(__meth__, *args, **kwargs)
@@ -233,7 +233,7 @@ def setUpClass(cls):
 
         docker_tests_enabled, sku = cls.docker_tests_enabled()
 
-        cls.host_stdout = None if is_envvar_true(PYAZURE_WEBHOST_DEBUG) \
+        cls.host_stdout = None if True \
             else tempfile.NamedTemporaryFile('w+t')
 
         try:
@@ -971,7 +971,7 @@ def popen_webhost(*, stdout, stderr, script_root=FUNCS_PATH, port=None):
 def start_webhost(*, script_dir=None, stdout=None):
     script_root = TESTS_ROOT / script_dir if script_dir else FUNCS_PATH
     if stdout is None:
-        if is_envvar_true(PYAZURE_WEBHOST_DEBUG):
+        if True:
             stdout = sys.stdout
         else:
             stdout = subprocess.DEVNULL