[EH] `az eventhubs namespace`: Add 2026-01 api version by schaudhari6254888 · Pull Request #33830 · Azure/azure-cli

schaudhari6254888 · 2026-08-02T12:53:37Z

🤖 PR Validation — ❌ Action needed

Breaking Changes	Tests
❌ 1	❌ 122/130

❌AzureCLI-BreakingChangeTest

❌eventhubs

rule cmd_name rule_message suggest_message

❌ 1007 - ParaRemove eventhubs cluster create cmd eventhubs cluster create removed parameter provisioning_state please add back parameter provisioning_state for cmd eventhubs cluster create

❌ 1007 - ParaRemove eventhubs cluster update cmd eventhubs cluster update removed parameter provisioning_state please add back parameter provisioning_state for cmd eventhubs cluster update

❌ 1007 - ParaRemove eventhubs eventhub update cmd eventhubs eventhub update removed parameter timestamp_type please add back parameter timestamp_type for cmd eventhubs eventhub update

❌ 1010 - ParaPropUpdate eventhubs eventhub update cmd eventhubs eventhub update update parameter min_compaction_lag_time_in_minutes: updated property options from ['--min-compaction-lag-in-mins', '--min-lag'] to ['--min-compaction-lag-time-in-minutes'] please change property options from ['--min-compaction-lag-time-in-minutes'] to ['--min-compaction-lag-in-mins', '--min-lag'] for parameter min_compaction_lag_time_in_minutes of cmd eventhubs eventhub update

❌ 1007 - ParaRemove eventhubs namespace failover cmd eventhubs namespace failover removed parameter no_wait please add back parameter no_wait for cmd eventhubs namespace failover

⚠️ 1006 - ParaAdd eventhubs cluster create cmd eventhubs cluster create added parameter platform_capabilities

⚠️ 1006 - ParaAdd eventhubs cluster create cmd eventhubs cluster create added parameter zone_redundant

⚠️ 1006 - ParaAdd eventhubs cluster list cmd eventhubs cluster list added parameter pagination_limit

⚠️ 1006 - ParaAdd eventhubs cluster list cmd eventhubs cluster list added parameter pagination_token

⚠️ 1006 - ParaAdd eventhubs cluster update cmd eventhubs cluster update added parameter platform_capabilities

⚠️ 1006 - ParaAdd eventhubs cluster update cmd eventhubs cluster update added parameter zone_redundant

⚠️ 1006 - ParaAdd eventhubs eventhub update cmd eventhubs eventhub update added parameter message_timestamp_description

⚠️ 1006 - ParaAdd eventhubs namespace create cmd eventhubs namespace create added parameter ip_address_type

⚠️ 1010 - ParaPropUpdate eventhubs namespace schema-registry create cmd eventhubs namespace schema-registry create update parameter schema_type: updated property choices from ['Avro', 'Unknown'] to ['Avro', 'Json', 'ProtoBuf', 'Unknown']

⚠️ 1010 - ParaPropUpdate eventhubs namespace schema-registry update cmd eventhubs namespace schema-registry update update parameter schema_type: updated property choices from ['Avro', 'Unknown'] to ['Avro', 'Json', 'ProtoBuf', 'Unknown']

⚠️ 1006 - ParaAdd eventhubs namespace update cmd eventhubs namespace update added parameter ip_address_type

⚠️ 1006 - ParaAdd eventhubs namespace update cmd eventhubs namespace update added parameter platform_capabilities

⚠️ 1010 - ParaPropUpdate eventhubs namespace update cmd eventhubs namespace update update parameter minimum_tls_version: updated property choices from ['1.0', '1.1', '1.2'] to ['1.0', '1.1', '1.2', '1.3']

Please submit your Breaking Change Pre-announcement ASAP if you haven't already. Please note:

Breaking changes can only be merged during the designated breaking change window
A pre-announcement must be released at least one month in advance

For more details on how to introduce breaking changes, refer to the documentation: azure-cli/doc/how_to_introduce_breaking_changes.md

❌AzureCLI-FullTest

️✔️acr

️✔️latest

️✔️3.12

️✔️3.14

️✔️acs

️✔️latest

️✔️3.12

️✔️3.14

🔄advisor

🔄latest

️✔️3.12

🔄3.14

️✔️ams

️✔️latest

️✔️3.12

️✔️3.14

️✔️apim

️✔️latest

️✔️3.12

️✔️3.14

🔄appconfig

🔄latest

️✔️3.12

🔄3.14

️✔️appservice

️✔️latest

️✔️3.12

️✔️3.14

️✔️aro

️✔️latest

️✔️3.12

️✔️3.14

️✔️backup

️✔️latest

️✔️3.12

️✔️3.14

️✔️batch

️✔️latest

️✔️3.12

️✔️3.14

️✔️batchai

️✔️latest

️✔️3.12

️✔️3.14

🔄billing

🔄latest

️✔️3.12

🔄3.14

️✔️botservice

️✔️latest

️✔️3.12

️✔️3.14

️✔️cloud

️✔️latest

️✔️3.12

️✔️3.14

🔄cognitiveservices

🔄latest

️✔️3.12

🔄3.14

️✔️compute_recommender

️✔️latest

️✔️3.12

️✔️3.14

️✔️computefleet

️✔️latest

️✔️3.12

️✔️3.14

️✔️config

️✔️latest

️✔️3.12

️✔️3.14

🔄configure

🔄latest

️✔️3.12

🔄3.14

🔄consumption

🔄latest

🔄3.12

️✔️3.14

️✔️container

️✔️latest

️✔️3.12

️✔️3.14

️✔️containerapp

️✔️latest

️✔️3.12

️✔️3.14

🔄core

🔄latest

️✔️3.12

🔄3.14

️✔️cosmosdb

️✔️latest

️✔️3.12

️✔️3.14

🔄databoxedge

🔄latest

️✔️3.12

🔄3.14

🔄dls

🔄latest

️✔️3.12

🔄3.14

🔄dms

🔄latest

️✔️3.12

🔄3.14

️✔️eventgrid

️✔️latest

️✔️3.12

️✔️3.14

❌eventhubs

❌latest

❌3.12

Type Test Case Error Message Line

Failed test_eh_cluster self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f4f8ced8140>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f4f8ddb9610>
command = 'eventhubs cluster create --resource-group test-migration --name eventhubs-clus1-000002 --location westus --tags {tag1:value1}'
expect_failure = False

    def in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
>           self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli-testsdk/azure/cli/testsdk/base.py:303:

env/lib/python3.12/site-packages/knack/cli.py:245: in invoke
    exit_code = self.exception_handler(ex)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler
    return handle_exception(ex)
           ^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception
    raise ex
env/lib/python3.12/site-packages/knack/cli.py:233: in invoke
    cmd_result = self.invocation.execute(args)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute
    raise ex
src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially
    results.append(self.run_job(expanded_arg, cmd_copy))
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job
    result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call
    result = poller.result()
             ^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result
    self.wait(timeout)
env/lib/python3.12/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer
    return func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait
    raise self.exception
src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start
    for polling_method in self.polling_generator:
                          ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/create.py:130: in execute_operations
    yield self.ClustersCreateOrUpdate(ctx=self.ctx)()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/create.py:150: in call
    session = self.client.send_request(request=request, stream=False, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request
    session = self.pipeline.run(request, stream=stream, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:242: in run
    return first_node.send(pipeline_request)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/mgmt/core/policies/base.py:95: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/policies/redirect.py:205: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/policies/retry.py:545: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:130: in send
    self.sender.send(request.http_request, **request.context.options),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send
    response = self.session.request(  # type: ignore
env/lib/python3.12/site-packages/requests/sessions.py:592: in request
    resp = self.send(prep, **send_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/requests/sessions.py:706: in send
    r = adapter.send(request, **kwargs)
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/requests/adapters.py:645: in send
    resp = conn.urlopen(
env/lib/python3.12/site-packages/urllib3/connectionpool.py:788: in urlopen
    response = self.make_request(
env/lib/python3.12/site-packages/urllib3/connectionpool.py:534: in make_request
    response = conn.getresponse()
               ^^^^^^^^^^^^^^^^^^


self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml(host='management.azure.com', port=443) at 0x7f4f8d121400>
= False, kwargs = {}

    def getresponse(self, =False, **kwargs):
        """Retrieve the response"""
        # Check to see if the cassette has a response for this request. If so,
        # then return it
        if self.cassette.can_play_response_for(self.vcr_request):
            log.info(f"Playing response for {self.vcr_request} from cassette")
            response = self.cassette.play_response(self.vcr_request)
            return VCRHTTPResponse(response, self.vcr_request.uri)
        else:
            if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request):
>               raise CannotOverwriteExistingCassetteException(
                    cassette=self.cassette,
                    failed_request=self.vcr_request,
                )
E               vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml') in your current record mode (RecordMode.ONCE: 'once').
E               No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2026-01-01>) was found.
E               Found 2 similar requests with 1 different matcher(s) :
E
E               1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None
E
E               2 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None

env/lib/python3.12/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException

During handling of the above exception, another exception occurred:

self = <azure.cli.command_modules.eventhubs.tests.latest.test_cluster_commands.EHNamespaceCURDScenarioTest testMethod=test_eh_cluster>

    @AllowLargeResponse()
    def test_eh_cluster(self):
        self.kwargs.update({
            'loc1': 'westcentralus',
            'loc': 'southcentralus',
            'rg': self.create_random_name(prefix='rg-cluster-', length=20),
            'clustername': self.create_random_name(prefix='eventhubs-clus1-', length=20),
            'namespacename': self.create_random_name(prefix='eventhubs-nscli', length=20),
            'tags': '{tag1:value1}',
            'tags2': '{tag2:value2}',
            'capacity': 1,
            'sku': 'Standard',
            'tier': 'Standard'
        })

        # Create Cluster
        # Created test-migration resource group for cluster cmdlets to monitor the cluster to save the cost.
        # Same resource group can be used to rerun the test or you can change the resource-group by replacing test-migration.
>       self.cmd('eventhubs cluster create --resource-group test-migration --name {clustername} --location westus --tags {tags}',
                 checks=[self.check('name', self.kwargs['clustername'])])

src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:38:

src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd
    return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init
    self.in_process_execute(cli_ctx, command, expect_failure=expect_failure)
                                       _

self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f4f8ced8140>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f4f8ddb9610>
command = 'eventhubs cluster create --resource-group test-migration --name eventhubs-clus1-000002 --location westus --tags {tag1:value1}'
expect_failure = False

    def _in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
            self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
            self.output = stdout_buf.getvalue()
            self.applog = logging_buf.getvalue()

        except CannotOverwriteExistingCassetteException as ex:
>           raise AssertionError(ex)
E           AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml') in your current record mode (RecordMode.ONCE: 'once').
E           No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2026-01-01>) was found.
E           Found 2 similar requests with 1 different matcher(s) :
E
E           1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None
E
E           2 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None

src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:19

Failed test_eh_self_serve_cluster The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:65

Failed test_eh_namespace The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands.py:19

Failed test_eh_alias The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_alias_test.py:18

Failed test_eh_authorization_rule The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_auth_rule_test.py:19

Failed test_eh_consumergroup The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_consumergroup_test.py:18

Failed test_eh_namespace_encryption The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_encryption_test.py:19

Failed test_eh_namespace_msi The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_msi_test.py:19

Failed test_eh_namespace_premium_standard The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_namespace_premium_test.py:19

Failed test_eh_network The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_network_test.py:18

Failed test_eh_privateendpoint The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_privateendpoint_test.py:18

Failed test_eh_create_update The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_entity_crud.py:19

Failed test_eventhub_app_group The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_application_group.py:19

Failed test_eventhub_schema_registry The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_schema_registry.py:19

❌3.14

Type Test Case Error Message Line

Failed test_eh_cluster self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f5b74de4ec0>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f5b74e3f750>
command = 'eventhubs cluster create --resource-group test-migration --name eventhubs-clus1-000002 --location westus --tags {tag1:value1}'
expect_failure = False

    def in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
>           self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli-testsdk/azure/cli/testsdk/base.py:303:

env/lib/python3.14/site-packages/knack/cli.py:245: in invoke
    exit_code = self.exception_handler(ex)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler
    return handle_exception(ex)
           ^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception
    raise ex
env/lib/python3.14/site-packages/knack/cli.py:233: in invoke
    cmd_result = self.invocation.execute(args)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute
    raise ex
src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially
    results.append(self.run_job(expanded_arg, cmd_copy))
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job
    result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call
    result = poller.result()
             ^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result
    self.wait(timeout)
env/lib/python3.14/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer
    return func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait
    raise self.exception
src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start
    for polling_method in self.polling_generator:
                          ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/create.py:130: in execute_operations
    yield self.ClustersCreateOrUpdate(ctx=self.ctx)()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/create.py:150: in call
    session = self.client.send_request(request=request, stream=False, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request
    session = self.pipeline.run(request, stream=stream, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:242: in run
    return first_node.send(pipeline_request)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/mgmt/core/policies/base.py:95: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/policies/redirect.py:205: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/policies/retry.py:545: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:130: in send
    self.sender.send(request.http_request, **request.context.options),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send
    response = self.session.request(  # type: ignore
env/lib/python3.14/site-packages/requests/sessions.py:592: in request
    resp = self.send(prep, **send_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/requests/sessions.py:706: in send
    r = adapter.send(request, **kwargs)
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/requests/adapters.py:645: in send
    resp = conn.urlopen(
env/lib/python3.14/site-packages/urllib3/connectionpool.py:788: in urlopen
    response = self.make_request(
env/lib/python3.14/site-packages/urllib3/connectionpool.py:534: in make_request
    response = conn.getresponse()
               ^^^^^^^^^^^^^^^^^^


self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml(host='management.azure.com', port=443) at 0x7f5b742f1940>
= False, kwargs = {}

    def getresponse(self, =False, **kwargs):
        """Retrieve the response"""
        # Check to see if the cassette has a response for this request. If so,
        # then return it
        if self.cassette.can_play_response_for(self.vcr_request):
            log.info(f"Playing response for {self.vcr_request} from cassette")
            response = self.cassette.play_response(self.vcr_request)
            return VCRHTTPResponse(response, self.vcr_request.uri)
        else:
            if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request):
>               raise CannotOverwriteExistingCassetteException(
                    cassette=self.cassette,
                    failed_request=self.vcr_request,
                )
E               vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml') in your current record mode (RecordMode.ONCE: 'once').
E               No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2026-01-01>) was found.
E               Found 2 similar requests with 1 different matcher(s) :
E
E               1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None
E
E               2 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None

env/lib/python3.14/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException

During handling of the above exception, another exception occurred:

self = <azure.cli.command_modules.eventhubs.tests.latest.test_cluster_commands.EHNamespaceCURDScenarioTest testMethod=test_eh_cluster>

    @AllowLargeResponse()
    def test_eh_cluster(self):
        self.kwargs.update({
            'loc1': 'westcentralus',
            'loc': 'southcentralus',
            'rg': self.create_random_name(prefix='rg-cluster-', length=20),
            'clustername': self.create_random_name(prefix='eventhubs-clus1-', length=20),
            'namespacename': self.create_random_name(prefix='eventhubs-nscli', length=20),
            'tags': '{tag1:value1}',
            'tags2': '{tag2:value2}',
            'capacity': 1,
            'sku': 'Standard',
            'tier': 'Standard'
        })

        # Create Cluster
        # Created test-migration resource group for cluster cmdlets to monitor the cluster to save the cost.
        # Same resource group can be used to rerun the test or you can change the resource-group by replacing test-migration.
>       self.cmd('eventhubs cluster create --resource-group test-migration --name {clustername} --location westus --tags {tags}',
                 checks=[self.check('name', self.kwargs['clustername'])])

src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:38:

src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd
    return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init
    self.in_process_execute(cli_ctx, command, expect_failure=expect_failure)
                                       _

self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f5b74de4ec0>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f5b74e3f750>
command = 'eventhubs cluster create --resource-group test-migration --name eventhubs-clus1-000002 --location westus --tags {tag1:value1}'
expect_failure = False

    def _in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
            self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
            self.output = stdout_buf.getvalue()
            self.applog = logging_buf.getvalue()

        except CannotOverwriteExistingCassetteException as ex:
>           raise AssertionError(ex)
E           AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml') in your current record mode (RecordMode.ONCE: 'once').
E           No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2026-01-01>) was found.
E           Found 2 similar requests with 1 different matcher(s) :
E
E           1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None
E
E           2 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None

src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:19

Failed test_eh_self_serve_cluster The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:65

Failed test_eh_namespace The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands.py:19

Failed test_eh_alias The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_alias_test.py:18

Failed test_eh_authorization_rule The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_auth_rule_test.py:19

Failed test_eh_consumergroup The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_consumergroup_test.py:18

Failed test_eh_namespace_encryption The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_encryption_test.py:19

Failed test_eh_namespace_msi The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_msi_test.py:19

Failed test_eh_namespace_premium_standard The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_namespace_premium_test.py:19

Failed test_eh_network The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_network_test.py:18

Failed test_eh_privateendpoint The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_privateendpoint_test.py:18

Failed test_eh_create_update The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_entity_crud.py:19

Failed test_eventhub_app_group The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_application_group.py:19

Failed test_eventhub_schema_registry The error message is too long, please check the pipeline log for details. azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_schema_registry.py:19

️✔️feedback

️✔️latest

️✔️3.12

️✔️3.14

️✔️find

️✔️latest

️✔️3.12

️✔️3.14

️✔️hdinsight

️✔️latest

️✔️3.12

️✔️3.14

️✔️identity

️✔️latest

️✔️3.12

️✔️3.14

❌iot

❌latest

❌3.12

Type Test Case Error Message Line

Failed test_identity_hub The error message is too long, please check the pipeline log for details. azure/cli/command_modules/iot/tests/latest/test_iot_commands.py:441

Failed test_iot_hub The error message is too long, please check the pipeline log for details. azure/cli/command_modules/iot/tests/latest/test_iot_commands.py:24

🔄3.14

️✔️keyvault

️✔️latest

️✔️3.12

️✔️3.14

️✔️lab

️✔️latest

️✔️3.12

️✔️3.14

️✔️managedservices

️✔️latest

️✔️3.12

️✔️3.14

🔄maps

🔄latest

🔄3.12

️✔️3.14

🔄marketplaceordering

🔄latest

️✔️3.12

🔄3.14

❌monitor

❌latest

❌3.12

Type Test Case Error Message Line

Failed test_monitor_log_analytics_workspace_data_export self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f52bc984170>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f52c431c740>
command = 'eventhubs namespace create --resource-group cli_test_monitor_workspace_data_export000001 --name eventhubs-nscli000004'
expect_failure = False

    def in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
>           self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli-testsdk/azure/cli/testsdk/base.py:303:

env/lib/python3.12/site-packages/knack/cli.py:245: in invoke
    exit_code = self.exception_handler(ex)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler
    return handle_exception(ex)
           ^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception
    raise ex
env/lib/python3.12/site-packages/knack/cli.py:233: in invoke
    cmd_result = self.invocation.execute(args)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute
    raise ex
src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially
    results.append(self.run_job(expanded_arg, cmd_copy))
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job
    result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call
    result = poller.result()
             ^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result
    self.wait(timeout)
env/lib/python3.12/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer
    return func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait
    raise self.exception
src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start
    for polling_method in self.polling_generator:
                          ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:332: in execute_operations
    yield self.NamespacesCreateOrUpdate(ctx=self.ctx)()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:352: in call
    session = self.client.send_request(request=request, stream=False, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request
    session = self.pipeline.run(request, stream=stream, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:242: in run
    return first_node.send(pipeline_request)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/mgmt/core/policies/base.py:95: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/policies/redirect.py:205: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/policies/retry.py:545: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:130: in send
    self.sender.send(request.http_request, **request.context.options),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send
    response = self.session.request(  # type: ignore
env/lib/python3.12/site-packages/requests/sessions.py:592: in request
    resp = self.send(prep, **send_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/requests/sessions.py:706: in send
    r = adapter.send(request, **kwargs)
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/requests/adapters.py:645: in send
    resp = conn.urlopen(
env/lib/python3.12/site-packages/urllib3/connectionpool.py:788: in urlopen
    response = self.make_request(
env/lib/python3.12/site-packages/urllib3/connectionpool.py:534: in make_request
    response = conn.getresponse()
               ^^^^^^^^^^^^^^^^^^


self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/monitor/tests/latest/recordings/test_monitor_log_analytics_workspace_data_export.yaml(host='management.azure.com', port=443) at 0x7f52bc5ec6e0>
= False, kwargs = {}

    def getresponse(self, =False, **kwargs):
        """Retrieve the response"""
        # Check to see if the cassette has a response for this request. If so,
        # then return it
        if self.cassette.can_play_response_for(self.vcr_request):
            log.info(f"Playing response for {self.vcr_request} from cassette")
            response = self.cassette.play_response(self.vcr_request)
            return VCRHTTPResponse(response, self.vcr_request.uri)
        else:
            if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request):
>               raise CannotOverwriteExistingCassetteException(
                    cassette=self.cassette,
                    failed_request=self.vcr_request,
                )
E               vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/monitor/tests/latest/recordings/test_monitor_log_analytics_workspace_data_export.yaml') in your current record mode (RecordMode.ONCE: 'once').
E               No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2026-01-01>) was found.
E               Found 1 similar requests with 1 different matcher(s) :
E
E               1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2024-05-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None

env/lib/python3.12/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException

During handling of the above exception, another exception occurred:

self = <azure.cli.command_modules.monitor.tests.latest.test_monitor_log_analytics_workspace.TestLogProfileScenarios testMethod=test_monitor_log_analytics_workspace_data_export>
resource_group = 'cli_test_monitor_workspace_data_export000001'
account_1 = 'saws1000002'

    @ResourceGroupPreparer(name_prefix='cli_test_monitor_workspace_data_export', location='eastus')
    @StorageAccountPreparer(name_prefix='saws1', kind='StorageV2', sku='Standard_LRS', parameter_name='account_1',
                            location='eastus')
    def test_monitor_log_analytics_workspace_data_export(self, resource_group, account_1):
        from azure.mgmt.core.tools import resource_id
        self.kwargs.update({
            'workspace_name': self.create_random_name('clitest', 20),
            'data_export_name': 'clitest',
            'data_export_name_2': 'clitest2',
            'sa_1': account_1,
            'sa_id_1': resource_id(
                resource_group=resource_group,
                subscription=self.get_subscription_id(),
                name=account_1,
                namespace='Microsoft.Storage',
                type='storageAccounts'),
            'namespacename': self.create_random_name(prefix='eventhubs-nscli', length=20),
            'eventhubname': "hub_name",
            'rg': resource_group
        })

        self.cmd(
            "monitor log-analytics workspace create -g {rg} -n {workspace_name} --quota 1 --level 100 --sku CapacityReservation",
            checks=[
                self.check('provisioningState', 'Succeeded'),
                self.check('retentionInDays', 30),
                self.check('sku.name', 'CapacityReservation'),
                self.check('sku.capacityReservationLevel', 100),
                self.check('workspaceCapping.dailyQuotaGb', 1.0)
            ])
        self.kwargs.update({
            'table_name': 'Syslog'
        })

        self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name} '
                 '--destination {sa_id_1} --enable -t {table_name}',
                 checks=[
                 ])

        from azure.core.exceptions import HttpResponseError
        with self.assertRaisesRegex(HttpResponseError, 'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t "SecurityEvent Heartbeat"',
                     checks=[
                     ])
        with self.assertRaisesRegex(HttpResponseError, 'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t {table_name}',
                     checks=[
                     ])
        with self.assertRaisesRegex(HttpResponseError, 'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t ABC',
                     checks=[
                     ])
        with self.assertRaisesRegex(HttpResponseError,'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t AppPerformanceCounters',
                     checks=[
                     ])
        self.cmd('monitor log-analytics workspace data-export show -g {rg} --workspace-name {workspace_name} -n {data_export_name}', checks=[
        ])

        self.cmd('monitor log-analytics workspace data-export list -g {rg} --workspace-name {workspace_name}', checks=[
            self.check('length(@)', 1)
        ])

>       result = self.cmd('eventhubs namespace create --resource-group {rg} --name {namespacename}').get_output_in_json()
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli/azure/cli/command_modules/monitor/tests/latest/test_monitor_log_analytics_workspace.py:506:

src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd
    return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init
    self.in_process_execute(cli_ctx, command, expect_failure=expect_failure)


self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f52bc984170>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f52c431c740>
command = 'eventhubs namespace create --resource-group cli_test_monitor_workspace_data_export000001 --name eventhubs-nscli000004'
expect_failure = False

    def _in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
            self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
            self.output = stdout_buf.getvalue()
            self.applog = logging_buf.getvalue()

        except CannotOverwriteExistingCassetteException as ex:
>           raise AssertionError(ex)
E           AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/monitor/tests/latest/recordings/test_monitor_log_analytics_workspace_data_export.yaml') in your current record mode (RecordMode.ONCE: 'once').
E           No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2026-01-01>) was found.
E           Found 1 similar requests with 1 different matcher(s) :
E
E           1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2024-05-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None

src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError azure/cli/command_modules/monitor/tests/latest/test_monitor_log_analytics_workspace.py:438

❌3.14

Type Test Case Error Message Line

Failed test_monitor_log_analytics_workspace_data_export self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f3962881f50>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f3966a5fd90>
command = 'eventhubs namespace create --resource-group cli_test_monitor_workspace_data_export000001 --name eventhubs-nscli000004'
expect_failure = False

    def in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
>           self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli-testsdk/azure/cli/testsdk/base.py:303:

env/lib/python3.14/site-packages/knack/cli.py:245: in invoke
    exit_code = self.exception_handler(ex)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler
    return handle_exception(ex)
           ^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception
    raise ex
env/lib/python3.14/site-packages/knack/cli.py:233: in invoke
    cmd_result = self.invocation.execute(args)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute
    raise ex
src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially
    results.append(self.run_job(expanded_arg, cmd_copy))
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job
    result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call
    result = poller.result()
             ^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result
    self.wait(timeout)
env/lib/python3.14/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer
    return func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait
    raise self.exception
src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start
    for polling_method in self.polling_generator:
                          ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:332: in execute_operations
    yield self.NamespacesCreateOrUpdate(ctx=self.ctx)()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:352: in call
    session = self.client.send_request(request=request, stream=False, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request
    session = self.pipeline.run(request, stream=stream, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:242: in run
    return first_node.send(pipeline_request)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/mgmt/core/policies/base.py:95: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/policies/redirect.py:205: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/policies/retry.py:545: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:130: in send
    self.sender.send(request.http_request, **request.context.options),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send
    response = self.session.request(  # type: ignore
env/lib/python3.14/site-packages/requests/sessions.py:592: in request
    resp = self.send(prep, **send_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/requests/sessions.py:706: in send
    r = adapter.send(request, **kwargs)
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/requests/adapters.py:645: in send
    resp = conn.urlopen(
env/lib/python3.14/site-packages/urllib3/connectionpool.py:788: in urlopen
    response = self.make_request(
env/lib/python3.14/site-packages/urllib3/connectionpool.py:534: in make_request
    response = conn.getresponse()
               ^^^^^^^^^^^^^^^^^^


self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/monitor/tests/latest/recordings/test_monitor_log_analytics_workspace_data_export.yaml(host='management.azure.com', port=443) at 0x7f3962c9d7f0>
= False, kwargs = {}

    def getresponse(self, =False, **kwargs):
        """Retrieve the response"""
        # Check to see if the cassette has a response for this request. If so,
        # then return it
        if self.cassette.can_play_response_for(self.vcr_request):
            log.info(f"Playing response for {self.vcr_request} from cassette")
            response = self.cassette.play_response(self.vcr_request)
            return VCRHTTPResponse(response, self.vcr_request.uri)
        else:
            if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request):
>               raise CannotOverwriteExistingCassetteException(
                    cassette=self.cassette,
                    failed_request=self.vcr_request,
                )
E               vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/monitor/tests/latest/recordings/test_monitor_log_analytics_workspace_data_export.yaml') in your current record mode (RecordMode.ONCE: 'once').
E               No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2026-01-01>) was found.
E               Found 1 similar requests with 1 different matcher(s) :
E
E               1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2024-05-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None

env/lib/python3.14/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException

During handling of the above exception, another exception occurred:

self = <azure.cli.command_modules.monitor.tests.latest.test_monitor_log_analytics_workspace.TestLogProfileScenarios testMethod=test_monitor_log_analytics_workspace_data_export>
resource_group = 'cli_test_monitor_workspace_data_export000001'
account_1 = 'saws1000002'

    @ResourceGroupPreparer(name_prefix='cli_test_monitor_workspace_data_export', location='eastus')
    @StorageAccountPreparer(name_prefix='saws1', kind='StorageV2', sku='Standard_LRS', parameter_name='account_1',
                            location='eastus')
    def test_monitor_log_analytics_workspace_data_export(self, resource_group, account_1):
        from azure.mgmt.core.tools import resource_id
        self.kwargs.update({
            'workspace_name': self.create_random_name('clitest', 20),
            'data_export_name': 'clitest',
            'data_export_name_2': 'clitest2',
            'sa_1': account_1,
            'sa_id_1': resource_id(
                resource_group=resource_group,
                subscription=self.get_subscription_id(),
                name=account_1,
                namespace='Microsoft.Storage',
                type='storageAccounts'),
            'namespacename': self.create_random_name(prefix='eventhubs-nscli', length=20),
            'eventhubname': "hub_name",
            'rg': resource_group
        })

        self.cmd(
            "monitor log-analytics workspace create -g {rg} -n {workspace_name} --quota 1 --level 100 --sku CapacityReservation",
            checks=[
                self.check('provisioningState', 'Succeeded'),
                self.check('retentionInDays', 30),
                self.check('sku.name', 'CapacityReservation'),
                self.check('sku.capacityReservationLevel', 100),
                self.check('workspaceCapping.dailyQuotaGb', 1.0)
            ])
        self.kwargs.update({
            'table_name': 'Syslog'
        })

        self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name} '
                 '--destination {sa_id_1} --enable -t {table_name}',
                 checks=[
                 ])

        from azure.core.exceptions import HttpResponseError
        with self.assertRaisesRegex(HttpResponseError, 'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t "SecurityEvent Heartbeat"',
                     checks=[
                     ])
        with self.assertRaisesRegex(HttpResponseError, 'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t {table_name}',
                     checks=[
                     ])
        with self.assertRaisesRegex(HttpResponseError, 'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t ABC',
                     checks=[
                     ])
        with self.assertRaisesRegex(HttpResponseError,'You are adding a destination that is already defined in rule: clitest. Destination must be unique across export rules in your workspace. See http://aka.ms/LADataExport#limitations'):
            self.cmd('monitor log-analytics workspace data-export create -g {rg} --workspace-name {workspace_name} -n {data_export_name_2} '
                     '--destination {sa_id_1} --enable -t AppPerformanceCounters',
                     checks=[
                     ])
        self.cmd('monitor log-analytics workspace data-export show -g {rg} --workspace-name {workspace_name} -n {data_export_name}', checks=[
        ])

        self.cmd('monitor log-analytics workspace data-export list -g {rg} --workspace-name {workspace_name}', checks=[
            self.check('length(@)', 1)
        ])

>       result = self.cmd('eventhubs namespace create --resource-group {rg} --name {namespacename}').get_output_in_json()
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli/azure/cli/command_modules/monitor/tests/latest/test_monitor_log_analytics_workspace.py:506:

src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd
    return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init
    self.in_process_execute(cli_ctx, command, expect_failure=expect_failure)


self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f3962881f50>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f3966a5fd90>
command = 'eventhubs namespace create --resource-group cli_test_monitor_workspace_data_export000001 --name eventhubs-nscli000004'
expect_failure = False

    def _in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
            self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
            self.output = stdout_buf.getvalue()
            self.applog = logging_buf.getvalue()

        except CannotOverwriteExistingCassetteException as ex:
>           raise AssertionError(ex)
E           AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/monitor/tests/latest/recordings/test_monitor_log_analytics_workspace_data_export.yaml') in your current record mode (RecordMode.ONCE: 'once').
E           No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2026-01-01>) was found.
E           Found 1 similar requests with 1 different matcher(s) :
E
E           1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_monitor_workspace_data_export000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000004?api-version=2024-05-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None

src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError azure/cli/command_modules/monitor/tests/latest/test_monitor_log_analytics_workspace.py:438

️✔️mysql

️✔️latest

️✔️3.12

️✔️3.14

️✔️netappfiles

️✔️latest

️✔️3.12

️✔️3.14

❌network

❌latest

🔄3.12

❌3.14

Type Test Case Error Message Line

Failed test_private_endpoint_connection_eventhub self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f9bf26a8cd0>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f9bf0d67ed0>
command = 'eventhubs namespace create -g test_private_endpoint_connection_eventhub000001 -n cli-test-resource-000006 '
expect_failure = False

    def in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
>           self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli-testsdk/azure/cli/testsdk/base.py:303:

env/lib/python3.14/site-packages/knack/cli.py:245: in invoke
    exit_code = self.exception_handler(ex)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler
    return handle_exception(ex)
           ^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception
    raise ex
env/lib/python3.14/site-packages/knack/cli.py:233: in invoke
    cmd_result = self.invocation.execute(args)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute
    raise ex
src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially
    results.append(self.run_job(expanded_arg, cmd_copy))
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job
    result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call
    result = poller.result()
             ^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result
    self.wait(timeout)
env/lib/python3.14/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer
    return func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait
    raise self.exception
src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start
    for polling_method in self.polling_generator:
                          ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:332: in execute_operations
    yield self.NamespacesCreateOrUpdate(ctx=self.ctx)()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:352: in call
    session = self.client.send_request(request=request, stream=False, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request
    session = self.pipeline.run(request, stream=stream, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:242: in run
    return first_node.send(pipeline_request)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/mgmt/core/policies/base.py:95: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/policies/redirect.py:205: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/policies/retry.py:545: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/base.py:130: in send
    self.sender.send(request.http_request, **request.context.options),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send
    response = self.session.request(  # type: ignore
env/lib/python3.14/site-packages/requests/sessions.py:592: in request
    resp = self.send(prep, **send_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/requests/sessions.py:706: in send
    r = adapter.send(request, **kwargs)
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.14/site-packages/requests/adapters.py:645: in send
    resp = conn.urlopen(
env/lib/python3.14/site-packages/urllib3/connectionpool.py:788: in urlopen
    response = self.make_request(
env/lib/python3.14/site-packages/urllib3/connectionpool.py:534: in make_request
    response = conn.getresponse()
               ^^^^^^^^^^^^^^^^^^


self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/network/tests/latest/recordings/test_private_endpoint_connection_eventhub.yaml(host='management.azure.com', port=443) at 0x7f9bf12839d0>
= False, kwargs = {}

    def getresponse(self, =False, **kwargs):
        """Retrieve the response"""
        # Check to see if the cassette has a response for this request. If so,
        # then return it
        if self.cassette.can_play_response_for(self.vcr_request):
            log.info(f"Playing response for {self.vcr_request} from cassette")
            response = self.cassette.play_response(self.vcr_request)
            return VCRHTTPResponse(response, self.vcr_request.uri)
        else:
            if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request):
>               raise CannotOverwriteExistingCassetteException(
                    cassette=self.cassette,
                    failed_request=self.vcr_request,
                )
E               vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/network/tests/latest/recordings/test_private_endpoint_connection_eventhub.yaml') in your current record mode (RecordMode.ONCE: 'once').
E               No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test_private_endpoint_connection_eventhub000001/providers/Microsoft.EventHub/namespaces/cli-test-resource-000006?api-version=2026-01-01>) was found.
E               Found 1 similar requests with 1 different matcher(s) :
E
E               1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test_private_endpoint_connection_eventhub000001/providers/Microsoft.EventHub/namespaces/cli-test-resource-000006?api-version=2024-05-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None

env/lib/python3.14/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException

During handling of the above exception, another exception occurred:

self = <azure.cli.command_modules.network.tests.latest.test_private_endpoint_commands.NetworkPrivateLinkScenarioTest testMethod=test_private_endpoint_connection_eventhub>
resource_group = 'test_private_endpoint_connection_eventhub000001'

    @ResourceGroupPreparer(name_prefix="test_private_endpoint_connection_eventhub", location="westus")
    def test_private_endpoint_connection_eventhub(self, resource_group):
        self.kwargs.update({
            'rg': resource_group,
            # config begin
            'cmd': 'eventhubs namespace',
            'list_num': 1,
            'type': 'Microsoft.EventHub/namespaces',
        })

>       test_private_endpoint(self, approve=False)

src/azure-cli/azure/cli/command_modules/network/tests/latest/test_private_endpoint_commands.py:2924:

src/azure-cli/azure/cli/command_modules/network/tests/latest/test_private_endpoint_commands.py:2858: in test_private_endpoint
    self.cmd('{cmd} create -g {rg} {create_name} {resource} {extra_create}')
src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd
    return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init
    self.in_process_execute(cli_ctx, command, expect_failure=expect_failure)


self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f9bf26a8cd0>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f9bf0d67ed0>
command = 'eventhubs namespace create -g test_private_endpoint_connection_eventhub000001 -n cli-test-resource-000006 '
expect_failure = False

    def _in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
            self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
            self.output = stdout_buf.getvalue()
            self.applog = logging_buf.getvalue()

        except CannotOverwriteExistingCassetteException as ex:
>           raise AssertionError(ex)
E           AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/network/tests/latest/recordings/test_private_endpoint_connection_eventhub.yaml') in your current record mode (RecordMode.ONCE: 'once').
E           No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test_private_endpoint_connection_eventhub000001/providers/Microsoft.EventHub/namespaces/cli-test-resource-000006?api-version=2026-01-01>) was found.
E           Found 1 similar requests with 1 different matcher(s) :
E
E           1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test_private_endpoint_connection_eventhub000001/providers/Microsoft.EventHub/namespaces/cli-test-resource-000006?api-version=2024-05-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None

src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError src/azure-cli/azure/cli/command_modules/network/tests/latest/test_private_endpoint_commands.py:2913

🔄policyinsights

🔄latest

️✔️3.12

🔄3.14

️✔️postgresql

️✔️latest

️✔️3.12

️✔️3.14

️✔️privatedns

️✔️latest

️✔️3.12

️✔️3.14

️✔️profile

️✔️latest

️✔️3.12

️✔️3.14

️✔️rdbms

️✔️latest

️✔️3.12

️✔️3.14

️✔️redis

️✔️latest

️✔️3.12

️✔️3.14

️✔️relay

️✔️latest

️✔️3.12

️✔️3.14

️✔️resource

️✔️latest

️✔️3.12

️✔️3.14

️✔️role

️✔️latest

️✔️3.12

️✔️3.14

🔄search

🔄latest

️✔️3.12

🔄3.14

️✔️security

️✔️latest

️✔️3.12

️✔️3.14

️✔️servicebus

️✔️latest

️✔️3.12

️✔️3.14

️✔️serviceconnector

️✔️latest

️✔️3.12

️✔️3.14

️✔️servicefabric

️✔️latest

️✔️3.12

️✔️3.14

️✔️signalr

️✔️latest

️✔️3.12

️✔️3.14

❌sql

❌latest

❌3.12

Type Test Case Error Message Line

Failed test_sql_db_security_mgmt The error message is too long, please check the pipeline log for details. azure/cli/command_modules/sql/tests/latest/test_sql_commands.py:2208

Failed test_sql_server_security_mgmt self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f1b19e47ef0>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f1b1df0e9f0>
command = 'eventhubs namespace create -g clitest.rg000001 -n cliehnamespacedb01'
expect_failure = False

    def in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
>           self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

src/azure-cli-testsdk/azure/cli/testsdk/base.py:303:

env/lib/python3.12/site-packages/knack/cli.py:245: in invoke
    exit_code = self.exception_handler(ex)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler
    return handle_exception(ex)
           ^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception
    raise ex
env/lib/python3.12/site-packages/knack/cli.py:233: in invoke
    cmd_result = self.invocation.execute(args)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute
    raise ex
src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially
    results.append(self.run_job(expanded_arg, cmd_copy))
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job
    result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call
    result = poller.result()
             ^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result
    self.wait(timeout)
env/lib/python3.12/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer
    return func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait
    raise self.exception
src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start
    for polling_method in self.polling_generator:
                          ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:332: in execute_operations
    yield self.NamespacesCreateOrUpdate(ctx=self.ctx)()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/create.py:352: in call
    session = self.client.send_request(request=request, stream=False, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request
    session = self.pipeline.run(request, stream=stream, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:242: in run
    return first_node.send(pipeline_request)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/mgmt/core/policies/base.py:95: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/policies/redirect.py:205: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/policies/retry.py:545: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send
    response = self.next.send(request)
               ^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/base.py:130: in send
    self.sender.send(request.http_request, **request.context.options),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send
    response = self.session.request(  # type: ignore
env/lib/python3.12/site-packages/requests/sessions.py:592: in request
    resp = self.send(prep, **send_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/requests/sessions.py:706: in send
    r = adapter.send(request, **kwargs)
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
env/lib/python3.12/site-packages/requests/adapters.py:645: in send
    resp = conn.urlopen(
env/lib/python3.12/site-packages/urllib3/connectionpool.py:788: in urlopen
    response = self.make_request(
env/lib/python3.12/site-packages/urllib3/connectionpool.py:534: in make_request
    response = conn.getresponse()
               ^^^^^^^^^^^^^^^^^^


self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/sql/tests/latest/recordings/test_sql_server_security_mgmt.yaml(host='management.azure.com', port=443) at 0x7f1b19e8cd70>
= False, kwargs = {}

    def getresponse(self, =False, **kwargs):
        """Retrieve the response"""
        # Check to see if the cassette has a response for this request. If so,
        # then return it
        if self.cassette.can_play_response_for(self.vcr_request):
            log.info(f"Playing response for {self.vcr_request} from cassette")
            response = self.cassette.play_response(self.vcr_request)
            return VCRHTTPResponse(response, self.vcr_request.uri)
        else:
            if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request):
>               raise CannotOverwriteExistingCassetteException(
                    cassette=self.cassette,
                    failed_request=self.vcr_request,
                )
E               vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/sql/tests/latest/recordings/test_sql_server_security_mgmt.yaml') in your current record mode (RecordMode.ONCE: 'once').
E               No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/clitest.rg000001/providers/Microsoft.EventHub/namespaces/cliehnamespacedb01?api-version=2026-01-01>) was found.
E               Found 1 similar requests with 1 different matcher(s) :
E
E               1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/clitest.rg000001/providers/Microsoft.EventHub/namespaces/cliehnamespacedb01?api-version=2024-05-01-preview>).
E               Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E               Matchers failed :
E               custom_request_query_matcher - assertion failure :
E               None

env/lib/python3.12/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException

During handling of the above exception, another exception occurred:

self = <azure.cli.command_modules.sql.tests.latest.test_sql_commands.SqlServerSecurityScenarioTest testMethod=test_sql_server_security_mgmt>
resource_group = 'clitest.rg000001', resource_group_2 = 'clitest.rg000002'
resource_group_location = 'westus', server = 'clitestserver000003'
storage_account = 'clitest000004', storage_account_2 = 'clitest000005'

    @ResourceGroupPreparer(location='westeurope')
    @ResourceGroupPreparer(parameter_name='resource_group_2')
    @SqlServerPreparer(location='westeurope')
    @StorageAccountPreparer(location='westus')
    @StorageAccountPreparer(parameter_name='storage_account_2',
                            resource_group_parameter_name='resource_group_2')
    def test_sql_server_security_mgmt(self, resource_group, resource_group_2,
                                      resource_group_location, server,
                                      storage_account, storage_account_2):
        state_enabled = 'Enabled'
        state_disabled = 'Disabled'

        # get storage account endpoint and key
        storage_endpoint = self.get_storage_endpoint(storage_account, resource_group)
        key = self.get_storage_key(storage_account, resource_group)

        # get audit policy
        self.cmd('sql server audit-policy show -g {} -n {}'
                 .format(resource_group, server),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('blobStorageTargetState', state_disabled),
                     JMESPathCheck('logAnalyticsTargetState', state_disabled),
                     JMESPathCheck('eventHubTargetState', state_disabled),
                     JMESPathCheck('isAzureMonitorTargetEnabled', False)])

        # update audit policy - enable
        retention_days = 30
        audit_actions_input = 'DATABASE_LOGOUT_GROUP DATABASE_ROLE_MEMBER_CHANGE_GROUP'
        audit_actions_expected = ['DATABASE_LOGOUT_GROUP',
                                  'DATABASE_ROLE_MEMBER_CHANGE_GROUP']

        self.cmd('sql server audit-policy update -g {} -n {}'
                 ' --state {} --blob-storage-target-state {} --storage-key {} --storage-endpoint={}'
                 ' --retention-days={} --actions {}'
                 .format(resource_group, server, state_enabled, state_enabled, key,
                         storage_endpoint, retention_days, audit_actions_input),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('storageEndpoint', storage_endpoint),
                     JMESPathCheck('retentionDays', retention_days),
                     JMESPathCheck('auditActionsAndGroups', audit_actions_expected)])

        # get audit policy
        self.cmd('sql server audit-policy show -g {} -n {}'
                 .format(resource_group, server),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('blobStorageTargetState', state_enabled),
                     JMESPathCheck('logAnalyticsTargetState', state_disabled),
                     JMESPathCheck('eventHubTargetState', state_disabled),
                     JMESPathCheck('isAzureMonitorTargetEnabled', False)])

        # update audit policy - specify storage account and resource group. use secondary key
        storage_endpoint_2 = self.get_storage_endpoint(storage_account_2, resource_group_2)
        self.cmd('sql server audit-policy update -g {} -n {}'
                 ' --blob-storage-target-state {} --storage-account {}'
                 .format(resource_group, server, state_enabled, storage_account_2),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('storageEndpoint', storage_endpoint_2),
                     JMESPathCheck('retentionDays', retention_days),
                     JMESPathCheck('auditActionsAndGroups', audit_actions_expected)])

        # update audit policy - disable
        self.cmd('sql server audit-policy update -g {} -n {}'
                 ' --state {}'
                 .format(resource_group, server, state_disabled),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_disabled),
                     JMESPathCheck('retentionDays', retention_days),
                     JMESPathCheck('auditActionsAndGroups', audit_actions_expected)])

        # create log analytics workspace
        log_analytics_workspace_name = self.create_random_name("laws", 20)

        log_analytics_workspace_id = self.cmd('monitor log-analytics workspace create -g {} -n {}'
                                              .format(resource_group, log_analytics_workspace_name),
                                              checks=[
                                                  JMESPathCheck('resourceGroup', resource_group),
                                                  JMESPathCheck('name', log_analytics_workspace_name),
                                                  JMESPathCheck('provisioningState',
                                                                'Succeeded')]).get_output_in_json()['id']

        # update audit policy - enable log analytics target
        self.cmd('sql server audit-policy update -g {} -n {}'
                 ' --state {}'
                 ' --log-analytics-target-state {} --log-analytics-workspace-resource-id {}'
                 .format(resource_group, server, state_enabled, state_enabled, log_analytics_workspace_id),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('retentionDays', retention_days),
                     JMESPathCheck('auditActionsAndGroups', audit_actions_expected)])

        # get audit policy - verify logAnalyticsTargetState is enabled and isAzureMonitorTargetEnabled is true
        self.cmd('sql server audit-policy show -g {} -n {}'
                 .format(resource_group, server),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('blobStorageTargetState', state_enabled),
                     JMESPathCheck('logAnalyticsTargetState', state_enabled),
                     JMESPathCheck('eventHubTargetState', state_disabled),
                     JMESPathCheck('isAzureMonitorTargetEnabled', True)])

        # update audit policy - disable log analytics target
        self.cmd('sql server audit-policy update -g {} -n {}'
                 ' --state {} --log-analytics-target-state {}'
                 .format(resource_group, server, state_enabled, state_disabled),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('retentionDays', retention_days),
                     JMESPathCheck('auditActionsAndGroups', audit_actions_expected)])

        # get audit policy - verify logAnalyticsTargetState is disabled and isAzureMonitorTargetEnabled is false
        self.cmd('sql server audit-policy show -g {} -n {}'
                 .format(resource_group, server),
                 checks=[
                     JMESPathCheck('resourceGroup', resource_group),
                     JMESPathCheck('state', state_enabled),
                     JMESPathCheck('blobStorageTargetState', state_enabled),
                     JMESPathCheck('logAnalyticsTargetState', state_disabled),
                     JMESPathCheck('eventHubTargetState', state_disabled),
                     JMESPathCheck('isAzureMonitorTargetEnabled', False)])

        # create event hub namespace
        eventhub_namespace = 'cliehnamespacedb01'

>       self.cmd('eventhubs namespace create -g {} -n {}'
                 .format(resource_group, eventhub_namespace),
                 checks=[
                     JMESPathCheck('provisioningState', 'Succeeded')])

src/azure-cli/azure/cli/command_modules/sql/tests/latest/test_sql_commands.py:2601:

src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd
    return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init
    self.in_process_execute(cli_ctx, command, expect_failure=expect_failure)
                                       _

self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f1b19e47ef0>
cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f1b1df0e9f0>
command = 'eventhubs namespace create -g clitest.rg000001 -n cliehnamespacedb01'
expect_failure = False

    def _in_process_execute(self, cli_ctx, command, expect_failure=False):
        from io import StringIO
        from vcr.errors import CannotOverwriteExistingCassetteException

        if command.startswith('az '):
            command = command[3:]

        stdout_buf = StringIO()
        logging_buf = StringIO()
        try:
            # issue: stderr cannot be redirect in this form, as a result some failure information
            # is lost when command fails.
            self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0
            self.output = stdout_buf.getvalue()
            self.applog = logging_buf.getvalue()

        except CannotOverwriteExistingCassetteException as ex:
>           raise AssertionError(ex)
E           AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/sql/tests/latest/recordings/test_sql_server_security_mgmt.yaml') in your current record mode (RecordMode.ONCE: 'once').
E           No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/clitest.rg000001/providers/Microsoft.EventHub/namespaces/cliehnamespacedb01?api-version=2026-01-01>) was found.
E           Found 1 similar requests with 1 different matcher(s) :
E
E           1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/clitest.rg000001/providers/Microsoft.EventHub/namespaces/cliehnamespacedb01?api-version=2024-05-01-preview>).
E           Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path']
E           Matchers failed :
E           _custom_request_query_matcher - assertion failure :
E           None

src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError azure/cli/command_modules/sql/tests/latest/test_sql_commands.py:2466

Failed test_sql_server_ms_support_mgmt The error message is too long, please check the pipeline log for details. azure/cli/command_modules/sql/tests/latest/test_sql_commands.py:2889

🔄3.14

️✔️sqlvm

️✔️latest

️✔️3.12

️✔️3.14

️✔️storage

️✔️latest

️✔️3.12

️✔️3.14

❌synapse

❌latest

❌3.12

Type Test Case Error Message Line

Failed test_kusto_data_connection_event_grid The error message is too long, please check the pipeline log for details. azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:19

Failed test_kusto_data_connection_event_hub The error message is too long, please check the pipeline log for details. azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:272

Failed test_sql_pool_audit_policy_logentry_eventhub The error message is too long, please check the pipeline log for details. azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:1756

Failed test_sql_ws_audit_policy_logentry_eventhub The error message is too long, please check the pipeline log for details. azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:1598

🔄3.14

🔄telemetry

🔄latest

🔄3.12

️✔️3.14

️✔️util

️✔️latest

️✔️3.12

️✔️3.14

🔄vm

🔄latest

️✔️3.12

🔄3.14

Related command

Description

Testing Guide

History Notes

[Component Name 1] BREAKING CHANGE: az command a: Make some customer-facing breaking change
[Component Name 2] az command b: Add some customer-facing feature

This checklist is used to make sure that common guidelines for a pull request are followed.

The PR title and description has followed the guideline in Submitting Pull Requests.
I adhere to the Command Guidelines.
I adhere to the Error Handling Guidelines.

azure-pipelines · 2026-08-02T12:53:47Z

Azure Pipelines: There may be pipelines that require an authorized user to comment /azp run to run.

a0x1ab · 2026-08-02T12:56:04Z

/azp run

azure-pipelines · 2026-08-02T12:56:22Z

Azure Pipelines: Successfully started running 3 pipeline(s).

Copilot

Pull request overview

This PR updates the Event Hubs command module to use the 2026-01-01 management-plane API version across many AAZ-generated commands (namespaces, private endpoint connections, schema registry, network rule sets, clusters, etc.), and adjusts several live scenario tests accordingly. It also introduces/threads through new namespace properties like ip_address_type and updates identity/encryption shaping for the new API surface.

Changes:

Regenerate / update AAZ command implementations to api-version 2026-01-01, including schema/argument validation updates and new/updated properties (e.g., identity, platform capabilities).
Update custom glue code (namespace_custom.py, _params.py) to accept ip_address_type and handle the new nested identity shape in encryption key-vault properties.
Update live tests (locations, TLS minimum version expectations, extra role/KV policy setup, and additional waits).

Reviewed changes

Copilot reviewed 95 out of 96 changed files in this pull request and generated 7 comments.

Show a summary per file

File	Description
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_schema_registry.py	Change test location default.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_application_group.py	Change test location default.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_entity_crud.py	Change test location; add identity/role assignment propagation waits.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_namespace_premium_test.py	Update TLS min version assertions; adjust geo-replication inputs; update deletions.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_msi_test.py	Change test location default.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_encryption_test.py	Change test location; add KV policy for system-assigned identity.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_auth_rule_test.py	Change test location default.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_alias_test.py	Change GeoDR test locations; increase waits.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py	Change cluster/namespace creation locations; comment out cluster deletion.
src/azure-cli/azure/cli/command_modules/eventhubs/operations/namespace_custom.py	Handle nested identity in encryption config; pass through `ip_address_type`.
src/azure-cli/azure/cli/command_modules/eventhubs/action.py	Change default for missing `cluster_arm_id` in replica config action.
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/profile_2019_03_01_hybrid/eventhubs/namespace/authorization_rule/keys/__cmd_group.py	Update generated help text (hybrid profile).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/profile_2019_03_01_hybrid/eventhubs/namespace/authorization_rule/__cmd_group.py	Update generated help text (hybrid profile).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/profile_2019_03_01_hybrid/eventhubs/namespace/__cmd_group.py	Update generated help text (hybrid profile).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/profile_2019_03_01_hybrid/eventhubs/eventhub/authorization_rule/keys/__cmd_group.py	Update generated help text (hybrid profile).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/profile_2019_03_01_hybrid/eventhubs/eventhub/authorization_rule/__cmd_group.py	Update generated help text (hybrid profile).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/profile_2019_03_01_hybrid/eventhubs/__cmd_group.py	Update generated help text (hybrid profile).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/schema_registry/_update.py	Bump api-version to 2026-01-01; update schema args/enums (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/schema_registry/_show.py	Bump api-version to 2026-01-01; schema validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/schema_registry/_list.py	Bump api-version to 2026-01-01; response schema flags updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/schema_registry/_delete.py	Bump api-version to 2026-01-01; schema validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/schema_registry/_create.py	Bump api-version to 2026-01-01; schema args/enums updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_link_resource/_show.py	Bump api-version to 2026-01-01; schema validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_endpoint_connection/_wait.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_endpoint_connection/_update.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_endpoint_connection/_show.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_endpoint_connection/_list.py	Bump api-version to 2026-01-01; response schema flags updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_endpoint_connection/_delete.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/private_endpoint_connection/_create.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/nsp_configuration/_show.py	Bump api-version to 2026-01-01; adjust read-only/systemData schema (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/nsp_configuration/_list.py	Bump api-version to 2026-01-01; adjust schema; docstring changed (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/nsp_configuration/__cmd_group.py	Update generated help text (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/network_rule_set/_update.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/network_rule_set/_show.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/network_rule_set/_list.py	Bump api-version to 2026-01-01; response schema flags updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/network_rule_set/_create.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/keys/_renew.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/keys/_list.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/_update.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/_show.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/_list.py	Bump api-version to 2026-01-01; response schema flags updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/_delete.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/_create.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/authorization_rule/__cmd_group.py	Update generated help text (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/application_group/_update.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/application_group/_show.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/application_group/_list.py	Bump api-version to 2026-01-01; response schema flags updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/application_group/_delete.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/application_group/_create.py	Bump api-version to 2026-01-01; arg validation updates (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_wait.py	Bump api-version to 2026-01-01; update identity/encryption schema (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_update.py	Bump api-version to 2026-01-01; add `ip_address_type`/platform capabilities args (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_show.py	Bump api-version to 2026-01-01; update identity/platform capabilities schema (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_list.py	Bump api-version to 2026-01-01; adjust list operation wiring/schema (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_failover.py	Bump api-version to 2026-01-01; change failover execution flow (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_exists.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_delete.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_create.py	Bump api-version to 2026-01-01; add identity/ip/platform capabilities args (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/__cmd_group.py	Update generated help text (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/authorization_rule/keys/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/authorization_rule/_show.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/authorization_rule/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_show.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_fail_over.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_exists.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_delete.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_create.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/georecovery_alias/_break_pair.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_update.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_show.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_delete.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_create.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/keys/_renew.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/keys/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/_update.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/_show.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/_delete.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/authorization_rule/_create.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/_update.py	Bump api-version to 2026-01-01; change message timestamp args/aliases (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/_show.py	Bump api-version to 2026-01-01; retention schema rename (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/_list.py	Bump api-version to 2026-01-01; retention schema rename (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/_delete.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/_create.py	Bump api-version to 2026-01-01; change message timestamp args/aliases (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__cmd_group.py	Minor generated export formatting.
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/namespace/_list.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_wait.py	Bump api-version to 2026-01-01; add platform capabilities schema (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_update.py	Bump api-version to 2026-01-01; add platform capabilities/zone redundant args; LRO final-state change (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_show.py	Bump api-version to 2026-01-01; add platform capabilities schema (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_list.py	Bump api-version to 2026-01-01; pagination support; list wiring changes (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_delete.py	Bump api-version to 2026-01-01; LRO final-state change (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_create.py	Bump api-version to 2026-01-01; add platform capabilities/zone redundant args; LRO final-state change (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_available_region.py	Bump api-version to 2026-01-01 (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/__cmd_group.py	Update generated help text (generated).
src/azure-cli/azure/cli/command_modules/eventhubs/_params.py	Add `ip_address_type` argument to namespace command surface.

Suppressed comments (3)

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_failover.py:94

NamespacesFailover.__call__ only treats 200/201 as success and routes everything else to on_error. Namespace failover is typically an async operation that can return 202 Accepted; treating 202 as an error will make the command fail even when the service is behaving correctly.
src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_alias_test.py:116
The added fixed sleeps (time.sleep(600) and time.sleep(300)) significantly increase test duration and can still be flaky if backend propagation takes longer/shorter. Prefer polling on a concrete condition with a bounded timeout (similar to the existing provisioningState/pendingReplicationOperationsCount loops) instead of unconditional sleeps.
src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/namespace/_failover.py:167
on_200_201 is currently a no-op (pass), so even successful failover responses are ignored and nothing is stored in ctx.vars.instance for output. This makes it hard to validate success programmatically and is inconsistent with other generated commands.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

    def _handler(self, command_args):
        super()._handler(command_args)
-        return self.build_lro_poller(self._execute_operations, self._output)
+        self._execute_operations()
+        return None



        time.sleep(600)

        namespace = self.cmd('eventhubs namespace failover --name {namespacename3} --resource-group {rg} '
                             '--primary-location {loc2} ').get_output_in_json()



        self.kwargs.update({
-            'loc_south': 'SouthCentralUS',
-            'loc_north': 'NorthCentralUS',
+            'loc_south': 'eastus',
+            'loc_north': 'eastus',
            'rg': resource_group,


 class List(AAZCommand):
-    """List of current NetworkSecurityPerimeterConfiguration for Namespace
+    """List list of current NetworkSecurityPerimeterConfiguration for Namespace
    """


            raise CLIError('location-name and role-type are mandatory properties')

        if "cluster_arm_id" not in LocationObject:
-            LocationObject["cluster_arm_id"] = ''
+            LocationObject["cluster_arm_id"] = None




        # Delete cluster
        # commented as the cluster can be deleted only after 4 hours
-        self.cmd('eventhubs cluster delete --resource-group test-migration --name {clustername} --yes')
+        # self.cmd('eventhubs cluster delete --resource-group test-migration --name {clustername} --yes')


+        _args_schema.message_timestamp_description = AAZObjectArg(
+            options=["--message-timestamp-description"],
+            arg_group="Properties",
+            help="Properties of MessageTimestamp Description",
+        )


EH 2026

6fae5c9

schaudhari6254888 requested a review from a team as a code owner August 2, 2026 12:53

Copilot AI review requested due to automatic review settings August 2, 2026 12:53

azure-client-tools-bot-prd Bot added this to the September 2026 (2026-09-01) milestone Aug 2, 2026

microsoft-github-policy-service Bot requested a review from yonzhan August 2, 2026 12:54

Copilot started reviewing on behalf of schaudhari6254888 August 2, 2026 12:54 View session

schaudhari6254888 changed the title ~~[EH] `az eventhubs namespace: Add 2026-01 api version~~ [EH] az eventhubs namespace: Add 2026-01 api version Aug 2, 2026

Copilot AI reviewed Aug 2, 2026

View reviewed changes

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

[EH] `az eventhubs namespace`: Add 2026-01 api version - #33830

[EH] `az eventhubs namespace`: Add 2026-01 api version#33830
schaudhari6254888 wants to merge 1 commit into
Azure:devfrom
schaudhari6254888:Eh-2026

schaudhari6254888 commented Aug 2, 2026 •

edited by azure-client-tools-agent Bot

Loading

Uh oh!

azure-pipelines Bot commented Aug 2, 2026

Uh oh!

a0x1ab commented Aug 2, 2026

Uh oh!

azure-pipelines Bot commented Aug 2, 2026

Uh oh!

Copilot AI left a comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

rule	cmd_name	rule_message	suggest_message
❌ 1007 - ParaRemove	eventhubs cluster create	cmd `eventhubs cluster create` removed parameter `provisioning_state`	please add back parameter `provisioning_state` for cmd `eventhubs cluster create`
❌ 1007 - ParaRemove	eventhubs cluster update	cmd `eventhubs cluster update` removed parameter `provisioning_state`	please add back parameter `provisioning_state` for cmd `eventhubs cluster update`
❌ 1007 - ParaRemove	eventhubs eventhub update	cmd `eventhubs eventhub update` removed parameter `timestamp_type`	please add back parameter `timestamp_type` for cmd `eventhubs eventhub update`
❌ 1010 - ParaPropUpdate	eventhubs eventhub update	cmd `eventhubs eventhub update` update parameter `min_compaction_lag_time_in_minutes`: updated property `options` from `['--min-compaction-lag-in-mins', '--min-lag']` to `['--min-compaction-lag-time-in-minutes']`	please change property `options` from `['--min-compaction-lag-time-in-minutes']` to `['--min-compaction-lag-in-mins', '--min-lag']` for parameter `min_compaction_lag_time_in_minutes` of cmd `eventhubs eventhub update`
❌ 1007 - ParaRemove	eventhubs namespace failover	cmd `eventhubs namespace failover` removed parameter `no_wait`	please add back parameter `no_wait` for cmd `eventhubs namespace failover`
⚠️ 1006 - ParaAdd	eventhubs cluster create	cmd `eventhubs cluster create` added parameter `platform_capabilities`
⚠️ 1006 - ParaAdd	eventhubs cluster create	cmd `eventhubs cluster create` added parameter `zone_redundant`
⚠️ 1006 - ParaAdd	eventhubs cluster list	cmd `eventhubs cluster list` added parameter `pagination_limit`
⚠️ 1006 - ParaAdd	eventhubs cluster list	cmd `eventhubs cluster list` added parameter `pagination_token`
⚠️ 1006 - ParaAdd	eventhubs cluster update	cmd `eventhubs cluster update` added parameter `platform_capabilities`
⚠️ 1006 - ParaAdd	eventhubs cluster update	cmd `eventhubs cluster update` added parameter `zone_redundant`
⚠️ 1006 - ParaAdd	eventhubs eventhub update	cmd `eventhubs eventhub update` added parameter `message_timestamp_description`
⚠️ 1006 - ParaAdd	eventhubs namespace create	cmd `eventhubs namespace create` added parameter `ip_address_type`
⚠️ 1010 - ParaPropUpdate	eventhubs namespace schema-registry create	cmd `eventhubs namespace schema-registry create` update parameter `schema_type`: updated property `choices` from `['Avro', 'Unknown']` to `['Avro', 'Json', 'ProtoBuf', 'Unknown']`
⚠️ 1010 - ParaPropUpdate	eventhubs namespace schema-registry update	cmd `eventhubs namespace schema-registry update` update parameter `schema_type`: updated property `choices` from `['Avro', 'Unknown']` to `['Avro', 'Json', 'ProtoBuf', 'Unknown']`
⚠️ 1006 - ParaAdd	eventhubs namespace update	cmd `eventhubs namespace update` added parameter `ip_address_type`
⚠️ 1006 - ParaAdd	eventhubs namespace update	cmd `eventhubs namespace update` added parameter `platform_capabilities`
⚠️ 1010 - ParaPropUpdate	eventhubs namespace update	cmd `eventhubs namespace update` update parameter `minimum_tls_version`: updated property `choices` from `['1.0', '1.1', '1.2']` to `['1.0', '1.1', '1.2', '1.3']`

Type	Test Case	Error Message	Line
Failed	test_eh_cluster	self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f4f8ced8140> cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f4f8ddb9610> command = 'eventhubs cluster create --resource-group test-migration --name eventhubs-clus1-000002 --location westus --tags {tag1:value1}' expect_failure = False def in_process_execute(self, cli_ctx, command, expect_failure=False): from io import StringIO from vcr.errors import CannotOverwriteExistingCassetteException if command.startswith('az '): command = command[3:] stdout_buf = StringIO() logging_buf = StringIO() try: # issue: stderr cannot be redirect in this form, as a result some failure information # is lost when command fails. > self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-testsdk/azure/cli/testsdk/base.py:303: env/lib/python3.12/site-packages/knack/cli.py:245: in invoke exit_code = self.exception_handler(ex) ^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/init.py:153: in exception_handler return handle_exception(ex) ^^^^^^^^^^^^^^^^^^^^ src/azure-cli-testsdk/azure/cli/testsdk/patches.py:33: in handle_main_exception raise ex env/lib/python3.12/site-packages/knack/cli.py:233: in invoke cmd_result = self.invocation.execute(args) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/commands/init.py:677: in execute raise ex src/azure-cli-core/azure/cli/core/commands/init.py:820: in run_jobs_serially results.append(self.run_job(expanded_arg, cmd_copy)) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/commands/init.py:800: in run_job result = LongRunningOperation(cmd_copy.cli_ctx, 'Starting {}'.format(cmd_copy.name))(result) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/commands/init.py:1168: in call result = poller.result() ^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/aaz/poller.py:105: in result self.wait(timeout) env/lib/python3.12/site-packages/azure/core/tracing/decorator.py:119: in wrapper_use_tracer return func(args, kwargs) ^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/aaz/poller.py:127: in wait raise self.exception src/azure-cli-core/azure/cli/core/aaz/poller.py:80: in start for polling_method in self.polling_generator: ^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/create.py:130: in execute_operations yield self.ClustersCreateOrUpdate(ctx=self.ctx)() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/create.py:150: in call* session = self.client.send_request(request=request, stream=False, kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/aaz/client.py:107: in send_request session = self.pipeline.run(request, stream=stream, kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:242: in run return first_node.send(pipeline_request) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/mgmt/core/policies/base.py:95: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/policies/redirect.py:205: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/policies/retry.py:545: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-core/azure/cli/core/aaz/http_policy.py:112: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:98: in send response = self.next.send(request) ^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/base.py:130: in send self.sender.send(request.http_request, request.context.options), ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/azure/core/pipeline/transport/requests_basic.py:375: in send response = self.session.request( # type: ignore env/lib/python3.12/site-packages/requests/sessions.py:592: in request resp = self.send(prep, send_kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/requests/sessions.py:706: in send r = adapter.send(request, *kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ env/lib/python3.12/site-packages/requests/adapters.py:645: in send resp = conn.urlopen( env/lib/python3.12/site-packages/urllib3/connectionpool.py:788: in urlopen response = self.make_request( env/lib/python3.12/site-packages/urllib3/connectionpool.py:534: in make_request response = conn.getresponse() ^^^^^^^^^^^^^^^^^^ self = <VCRRequestsHTTPSConnection/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml(host='management.azure.com', port=443) at 0x7f4f8d121400>* = False, kwargs = {} def getresponse(self, =False, kwargs): """Retrieve the response""" # Check to see if the cassette has a response for this request. If so, # then return it if self.cassette.can_play_response_for(self.vcr_request): log.info(f"Playing response for {self.vcr_request} from cassette") response = self.cassette.play_response(self.vcr_request) return VCRHTTPResponse(response, self.vcr_request.uri) else: if self.cassette.write_protected and self.cassette.filter_request(self.vcr_request): > raise CannotOverwriteExistingCassetteException( cassette=self.cassette, failed_request=self.vcr_request, ) E vcr.errors.CannotOverwriteExistingCassetteException: Can't overwrite existing cassette ('/mnt/vss/work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml') in your current record mode (RecordMode.ONCE: 'once'). E No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2026-01-01>) was found. E Found 2 similar requests with 1 different matcher(s) : E E 1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>). E Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path'] E Matchers failed : E custom_request_query_matcher - assertion failure : E None E E 2 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>). E Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path'] E Matchers failed : E custom_request_query_matcher - assertion failure : E None env/lib/python3.12/site-packages/vcr/stubs/init.py:279: CannotOverwriteExistingCassetteException During handling of the above exception, another exception occurred: self = <azure.cli.command_modules.eventhubs.tests.latest.test_cluster_commands.EHNamespaceCURDScenarioTest testMethod=test_eh_cluster> @AllowLargeResponse() def test_eh_cluster(self): self.kwargs.update({ 'loc1': 'westcentralus', 'loc': 'southcentralus', 'rg': self.create_random_name(prefix='rg-cluster-', length=20), 'clustername': self.create_random_name(prefix='eventhubs-clus1-', length=20), 'namespacename': self.create_random_name(prefix='eventhubs-nscli', length=20), 'tags': '{tag1:value1}', 'tags2': '{tag2:value2}', 'capacity': 1, 'sku': 'Standard', 'tier': 'Standard' }) # Create Cluster # Created test-migration resource group for cluster cmdlets to monitor the cluster to save the cost. # Same resource group can be used to rerun the test or you can change the resource-group by replacing test-migration. > self.cmd('eventhubs cluster create --resource-group test-migration --name {clustername} --location westus --tags {tags}', checks=[self.check('name', self.kwargs['clustername'])]) src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:38: src/azure-cli-testsdk/azure/cli/testsdk/base.py:177: in cmd return execute(self.cli_ctx, command, expect_failure=expect_failure).assert_with_checks(checks) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ src/azure-cli-testsdk/azure/cli/testsdk/base.py:252: in init** self.in_process_execute(cli_ctx, command, expect_failure=expect_failure) _ self = <azure.cli.testsdk.base.ExecutionResult object at 0x7f4f8ced8140> cli_ctx = <azure.cli.core.mock.DummyCli object at 0x7f4f8ddb9610> command = 'eventhubs cluster create --resource-group test-migration --name eventhubs-clus1-000002 --location westus --tags {tag1:value1}' expect_failure = False def _in_process_execute(self, cli_ctx, command, expect_failure=False): from io import StringIO from vcr.errors import CannotOverwriteExistingCassetteException if command.startswith('az '): command = command[3:] stdout_buf = StringIO() logging_buf = StringIO() try: # issue: stderr cannot be redirect in this form, as a result some failure information # is lost when command fails. self.exit_code = cli_ctx.invoke(shlex.split(command), out_file=stdout_buf) or 0 self.output = stdout_buf.getvalue() self.applog = logging_buf.getvalue() except CannotOverwriteExistingCassetteException as ex: > raise AssertionError(ex) E AssertionError: Can't overwrite existing cassette ('/mnt/vss/_work/1/s/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_cluster.yaml') in your current record mode (RecordMode.ONCE: 'once'). E No match for the request (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2026-01-01>) was found. E Found 2 similar requests with 1 different matcher(s) : E E 1 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>). E Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path'] E Matchers failed : E _custom_request_query_matcher - assertion failure : E None E E 2 - (<Request (PUT) https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/test-migration/providers/Microsoft.EventHub/clusters/eventhubs-clus1-000002?api-version=2023-01-01-preview>). E Matchers succeeded : ['method', 'scheme', 'host', 'port', 'path'] E Matchers failed : E _custom_request_query_matcher - assertion failure : E None src/azure-cli-testsdk/azure/cli/testsdk/base.py:308: AssertionError	azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:19
Failed	test_eh_self_serve_cluster	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_cluster_commands.py:65
Failed	test_eh_namespace	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands.py:19
Failed	test_eh_alias	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_alias_test.py:18
Failed	test_eh_authorization_rule	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_auth_rule_test.py:19
Failed	test_eh_consumergroup	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_consumergroup_test.py:18
Failed	test_eh_namespace_encryption	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_encryption_test.py:19
Failed	test_eh_namespace_msi	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_msi_test.py:19
Failed	test_eh_namespace_premium_standard	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_namespace_premium_test.py:19
Failed	test_eh_network	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_network_test.py:18
Failed	test_eh_privateendpoint	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_commands_privateendpoint_test.py:18
Failed	test_eh_create_update	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_entity_crud.py:19
Failed	test_eventhub_app_group	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_application_group.py:19
Failed	test_eventhub_schema_registry	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/eventhubs/tests/latest/test_eventhub_namespace_schema_registry.py:19

Type	Test Case	Error Message	Line
Failed	test_identity_hub	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/iot/tests/latest/test_iot_commands.py:441
Failed	test_iot_hub	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/iot/tests/latest/test_iot_commands.py:24

Type	Test Case	Error Message	Line
Failed	test_kusto_data_connection_event_grid	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:19
Failed	test_kusto_data_connection_event_hub	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:272
Failed	test_sql_pool_audit_policy_logentry_eventhub	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:1756
Failed	test_sql_ws_audit_policy_logentry_eventhub	The error message is too long, please check the pipeline log for details.	azure/cli/command_modules/synapse/tests/latest/test_synapse_scenario.py:1598

Uh oh!

Conversation

schaudhari6254888 commented Aug 2, 2026 • edited by azure-client-tools-agent Bot Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

🤖 PR Validation — ❌ Action needed

Uh oh!

azure-pipelines Bot commented Aug 2, 2026

Uh oh!

a0x1ab commented Aug 2, 2026

Uh oh!

azure-pipelines Bot commented Aug 2, 2026

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

schaudhari6254888 commented Aug 2, 2026 •

edited by azure-client-tools-agent Bot

Loading