[ADLS] adding test_vnet_operations

.gitignore

@@ -1,6 +1,7 @@
 # Python cache
 __pycache__/
 *.pyc
+.pytest_cache
 
 # Virtual environment
 env*/

azure-common/azure/common/client_factory.py

@@ -52,7 +52,7 @@ def get_client_from_cli_profile(client_class, **kwargs):
     .. versionadded:: 1.1.6
 
     :param client_class: A SDK client class
-    :return: An instanciated client
+    :return: An instantiated client
     :raises: ImportError if azure-cli-core package is not available
     """
 
@@ -114,7 +114,7 @@ def get_client_from_json_dict(client_class, config_dict, **kwargs):
 
     :param client_class: A SDK client class
     :param dict config_dict: A config dict.
-    :return: An instanciated client
+    :return: An instantiated client
     """
     parameters = {
         'subscription_id': config_dict.get('subscriptionId'),
@@ -183,7 +183,7 @@ def get_client_from_auth_file(client_class, auth_path=None, **kwargs):
 
     :param client_class: A SDK client class
     :param str auth_path: Path to the file.
-    :return: An instanciated client
+    :return: An instantiated client
     :raises: KeyError if AZURE_AUTH_LOCATION is not an environment variable and no path is provided
     :raises: FileNotFoundError if provided file path does not exists
     :raises: json.JSONDecodeError if provided file is not JSON valid

azure-eventgrid/HISTORY.rst

@@ -3,6 +3,11 @@
 Release History
 ===============
 
+1.1.0 (2018-05-24)
+++++++++++++++++++
+
+- Event Schemas for EventGrid subscription validation event, Azure Media events, and ServiceBus events.
+
 1.0.0 (2018-04-26)
 ++++++++++++++++++
 

azure-eventgrid/azure/eventgrid/models/__init__.py

@@ -20,6 +20,9 @@
     from .resource_delete_failure_data_py3 import ResourceDeleteFailureData
     from .resource_delete_cancel_data_py3 import ResourceDeleteCancelData
     from .event_grid_event_py3 import EventGridEvent
+    from .subscription_validation_event_data_py3 import SubscriptionValidationEventData
+    from .subscription_validation_response_py3 import SubscriptionValidationResponse
+    from .subscription_deleted_event_data_py3 import SubscriptionDeletedEventData
     from .iot_hub_device_created_event_data_py3 import IotHubDeviceCreatedEventData
     from .iot_hub_device_deleted_event_data_py3 import IotHubDeviceDeletedEventData
     from .device_twin_metadata_py3 import DeviceTwinMetadata
@@ -35,6 +38,9 @@
     from .container_registry_event_actor_py3 import ContainerRegistryEventActor
     from .container_registry_event_source_py3 import ContainerRegistryEventSource
     from .container_registry_event_data_py3 import ContainerRegistryEventData
+    from .service_bus_active_messages_available_with_no_listeners_event_data_py3 import ServiceBusActiveMessagesAvailableWithNoListenersEventData
+    from .service_bus_deadletter_messages_available_with_no_listeners_event_data_py3 import ServiceBusDeadletterMessagesAvailableWithNoListenersEventData
+    from .media_job_state_change_event_data_py3 import MediaJobStateChangeEventData
 except (SyntaxError, ImportError):
     from .storage_blob_created_event_data import StorageBlobCreatedEventData
     from .storage_blob_deleted_event_data import StorageBlobDeletedEventData
@@ -46,6 +52,9 @@
     from .resource_delete_failure_data import ResourceDeleteFailureData
     from .resource_delete_cancel_data import ResourceDeleteCancelData
     from .event_grid_event import EventGridEvent
+    from .subscription_validation_event_data import SubscriptionValidationEventData
+    from .subscription_validation_response import SubscriptionValidationResponse
+    from .subscription_deleted_event_data import SubscriptionDeletedEventData
     from .iot_hub_device_created_event_data import IotHubDeviceCreatedEventData
     from .iot_hub_device_deleted_event_data import IotHubDeviceDeletedEventData
     from .device_twin_metadata import DeviceTwinMetadata
@@ -61,6 +70,12 @@
     from .container_registry_event_actor import ContainerRegistryEventActor
     from .container_registry_event_source import ContainerRegistryEventSource
     from .container_registry_event_data import ContainerRegistryEventData
+    from .service_bus_active_messages_available_with_no_listeners_event_data import ServiceBusActiveMessagesAvailableWithNoListenersEventData
+    from .service_bus_deadletter_messages_available_with_no_listeners_event_data import ServiceBusDeadletterMessagesAvailableWithNoListenersEventData
+    from .media_job_state_change_event_data import MediaJobStateChangeEventData
+from .event_grid_client_enums import (
+    JobState,
+)
 
 __all__ = [
     'StorageBlobCreatedEventData',
@@ -73,6 +88,9 @@
     'ResourceDeleteFailureData',
     'ResourceDeleteCancelData',
     'EventGridEvent',
+    'SubscriptionValidationEventData',
+    'SubscriptionValidationResponse',
+    'SubscriptionDeletedEventData',
     'IotHubDeviceCreatedEventData',
     'IotHubDeviceDeletedEventData',
     'DeviceTwinMetadata',
@@ -88,4 +106,8 @@
     'ContainerRegistryEventActor',
     'ContainerRegistryEventSource',
     'ContainerRegistryEventData',
+    'ServiceBusActiveMessagesAvailableWithNoListenersEventData',
+    'ServiceBusDeadletterMessagesAvailableWithNoListenersEventData',
+    'MediaJobStateChangeEventData',
+    'JobState',
 ]

azure-eventgrid/azure/eventgrid/models/container_registry_image_deleted_event_data_py3.py

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .container_registry_event_data import ContainerRegistryEventData
+from .container_registry_event_data_py3 import ContainerRegistryEventData
 
 
 class ContainerRegistryImageDeletedEventData(ContainerRegistryEventData):

azure-eventgrid/azure/eventgrid/models/container_registry_image_pushed_event_data_py3.py

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .container_registry_event_data import ContainerRegistryEventData
+from .container_registry_event_data_py3 import ContainerRegistryEventData
 
 
 class ContainerRegistryImagePushedEventData(ContainerRegistryEventData):

azure-eventgrid/azure/eventgrid/models/device_life_cycle_event_properties.py

@@ -19,7 +19,7 @@ class DeviceLifeCycleEventProperties(Model):
     :param device_id: The unique identifier of the device. This case-sensitive
      string can be up to 128 characters long, and supports ASCII 7-bit
      alphanumeric characters plus the following special characters: - : . + % _
-     # * ? ! ( ) , = @ ; $ '.
+     # * ? ! ( ) , = @ ; $ '.
     :type device_id: str
     :param hub_name: Name of the IoT Hub where the device was created or
      deleted.

azure-eventgrid/azure/eventgrid/models/device_life_cycle_event_properties_py3.py

@@ -19,7 +19,7 @@ class DeviceLifeCycleEventProperties(Model):
     :param device_id: The unique identifier of the device. This case-sensitive
      string can be up to 128 characters long, and supports ASCII 7-bit
      alphanumeric characters plus the following special characters: - : . + % _
-     # * ? ! ( ) , = @ ; $ '.
+     # * ? ! ( ) , = @ ; $ '.
     :type device_id: str
     :param hub_name: Name of the IoT Hub where the device was created or
      deleted.

azure-eventgrid/azure/eventgrid/models/event_grid_client_enums.py

@@ -0,0 +1,23 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from enum import Enum
+
+
+class JobState(str, Enum):
+
+    canceled = "Canceled"  #: The job was canceled. This is a final state for the job.
+    canceling = "Canceling"  #: The job is in the process of being canceled. This is a transient state for the job.
+    error = "Error"  #: The job has encountered an error. This is a final state for the job.
+    finished = "Finished"  #: The job is finished. This is a final state for the job.
+    processing = "Processing"  #: The job is processing. This is a transient state for the job.
+    queued = "Queued"  #: The job is in a queued state, waiting for resources to become available. This is a transient state.
+    scheduled = "Scheduled"  #: The job is being scheduled to run on an available resource. This is a transient state, between queued and processing states.

azure-eventgrid/azure/eventgrid/models/iot_hub_device_created_event_data.py

@@ -18,7 +18,7 @@ class IotHubDeviceCreatedEventData(DeviceLifeCycleEventProperties):
     :param device_id: The unique identifier of the device. This case-sensitive
      string can be up to 128 characters long, and supports ASCII 7-bit
      alphanumeric characters plus the following special characters: - : . + % _
-     # * ? ! ( ) , = @ ; $ '.
+     # * ? ! ( ) , = @ ; $ '.
     :type device_id: str
     :param hub_name: Name of the IoT Hub where the device was created or
      deleted.

azure-eventgrid/azure/eventgrid/models/iot_hub_device_created_event_data_py3.py

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .device_life_cycle_event_properties import DeviceLifeCycleEventProperties
+from .device_life_cycle_event_properties_py3 import DeviceLifeCycleEventProperties
 
 
 class IotHubDeviceCreatedEventData(DeviceLifeCycleEventProperties):
@@ -18,7 +18,7 @@ class IotHubDeviceCreatedEventData(DeviceLifeCycleEventProperties):
     :param device_id: The unique identifier of the device. This case-sensitive
      string can be up to 128 characters long, and supports ASCII 7-bit
      alphanumeric characters plus the following special characters: - : . + % _
-     # * ? ! ( ) , = @ ; $ '.
+     # * ? ! ( ) , = @ ; $ '.
     :type device_id: str
     :param hub_name: Name of the IoT Hub where the device was created or
      deleted.

azure-eventgrid/azure/eventgrid/models/iot_hub_device_deleted_event_data.py

@@ -18,7 +18,7 @@ class IotHubDeviceDeletedEventData(DeviceLifeCycleEventProperties):
     :param device_id: The unique identifier of the device. This case-sensitive
      string can be up to 128 characters long, and supports ASCII 7-bit
      alphanumeric characters plus the following special characters: - : . + % _
-     # * ? ! ( ) , = @ ; $ '.
+     # * ? ! ( ) , = @ ; $ '.
     :type device_id: str
     :param hub_name: Name of the IoT Hub where the device was created or
      deleted.

azure-eventgrid/azure/eventgrid/models/iot_hub_device_deleted_event_data_py3.py

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .device_life_cycle_event_properties import DeviceLifeCycleEventProperties
+from .device_life_cycle_event_properties_py3 import DeviceLifeCycleEventProperties
 
 
 class IotHubDeviceDeletedEventData(DeviceLifeCycleEventProperties):
@@ -18,7 +18,7 @@ class IotHubDeviceDeletedEventData(DeviceLifeCycleEventProperties):
     :param device_id: The unique identifier of the device. This case-sensitive
      string can be up to 128 characters long, and supports ASCII 7-bit
      alphanumeric characters plus the following special characters: - : . + % _
-     # * ? ! ( ) , = @ ; $ '.
+     # * ? ! ( ) , = @ ; $ '.
     :type device_id: str
     :param hub_name: Name of the IoT Hub where the device was created or
      deleted.

azure-eventgrid/azure/eventgrid/models/media_job_state_change_event_data.py

@@ -0,0 +1,45 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class MediaJobStateChangeEventData(Model):
+    """Schema of the Data property of an EventGridEvent for a
+    Microsoft.Media.JobStateChange event.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    :ivar previous_state: The previous state of the Job. Possible values
+     include: 'Canceled', 'Canceling', 'Error', 'Finished', 'Processing',
+     'Queued', 'Scheduled'
+    :vartype previous_state: str or ~azure.eventgrid.models.JobState
+    :ivar state: The new state of the Job. Possible values include:
+     'Canceled', 'Canceling', 'Error', 'Finished', 'Processing', 'Queued',
+     'Scheduled'
+    :vartype state: str or ~azure.eventgrid.models.JobState
+    """
+
+    _validation = {
+        'previous_state': {'readonly': True},
+        'state': {'readonly': True},
+    }
+
+    _attribute_map = {
+        'previous_state': {'key': 'previousState', 'type': 'JobState'},
+        'state': {'key': 'state', 'type': 'JobState'},
+    }
+
+    def __init__(self, **kwargs):
+        super(MediaJobStateChangeEventData, self).__init__(**kwargs)
+        self.previous_state = None
+        self.state = None

azure-eventgrid/azure/eventgrid/models/media_job_state_change_event_data_py3.py

@@ -0,0 +1,45 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class MediaJobStateChangeEventData(Model):
+    """Schema of the Data property of an EventGridEvent for a
+    Microsoft.Media.JobStateChange event.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    :ivar previous_state: The previous state of the Job. Possible values
+     include: 'Canceled', 'Canceling', 'Error', 'Finished', 'Processing',
+     'Queued', 'Scheduled'
+    :vartype previous_state: str or ~azure.eventgrid.models.JobState
+    :ivar state: The new state of the Job. Possible values include:
+     'Canceled', 'Canceling', 'Error', 'Finished', 'Processing', 'Queued',
+     'Scheduled'
+    :vartype state: str or ~azure.eventgrid.models.JobState
+    """
+
+    _validation = {
+        'previous_state': {'readonly': True},
+        'state': {'readonly': True},
+    }
+
+    _attribute_map = {
+        'previous_state': {'key': 'previousState', 'type': 'JobState'},
+        'state': {'key': 'state', 'type': 'JobState'},
+    }
+
+    def __init__(self, **kwargs) -> None:
+        super(MediaJobStateChangeEventData, self).__init__(**kwargs)
+        self.previous_state = None
+        self.state = None

azure-eventgrid/azure/eventgrid/models/service_bus_active_messages_available_with_no_listeners_event_data.py

@@ -0,0 +1,55 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class ServiceBusActiveMessagesAvailableWithNoListenersEventData(Model):
+    """Schema of the Data property of an EventGridEvent for a
+    Microsoft.ServiceBus.ActiveMessagesAvailableWithNoListeners event.
+
+    :param namespace_name: The namespace name of the Microsoft.ServiceBus
+     resource.
+    :type namespace_name: str
+    :param request_uri: The endpoint of the Microsoft.ServiceBus resource.
+    :type request_uri: str
+    :param entity_type: The entity type of the Microsoft.ServiceBus resource.
+     Could be one of 'queue' or 'subscriber'.
+    :type entity_type: str
+    :param queue_name: The name of the Microsoft.ServiceBus queue. If the
+     entity type is of type 'subscriber', then this value will be null.
+    :type queue_name: str
+    :param topic_name: The name of the Microsoft.ServiceBus topic. If the
+     entity type is of type 'queue', then this value will be null.
+    :type topic_name: str
+    :param subscription_name: The name of the Microsoft.ServiceBus topic's
+     subscription. If the entity type is of type 'queue', then this value will
+     be null.
+    :type subscription_name: str
+    """
+
+    _attribute_map = {
+        'namespace_name': {'key': 'namespaceName', 'type': 'str'},
+        'request_uri': {'key': 'requestUri', 'type': 'str'},
+        'entity_type': {'key': 'entityType', 'type': 'str'},
+        'queue_name': {'key': 'queueName', 'type': 'str'},
+        'topic_name': {'key': 'topicName', 'type': 'str'},
+        'subscription_name': {'key': 'subscriptionName', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(ServiceBusActiveMessagesAvailableWithNoListenersEventData, self).__init__(**kwargs)
+        self.namespace_name = kwargs.get('namespace_name', None)
+        self.request_uri = kwargs.get('request_uri', None)
+        self.entity_type = kwargs.get('entity_type', None)
+        self.queue_name = kwargs.get('queue_name', None)
+        self.topic_name = kwargs.get('topic_name', None)
+        self.subscription_name = kwargs.get('subscription_name', None)