Hello community,

here is the log from the commit of package azure-cli-iot for openSUSE:Factory 
checked in at 2018-05-13 16:02:30
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Comparing /work/SRC/openSUSE:Factory/azure-cli-iot (Old)
 and      /work/SRC/openSUSE:Factory/.azure-cli-iot.new (New)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

Package is "azure-cli-iot"

Sun May 13 16:02:30 2018 rev:3 rq:600055 version:0.1.19

Changes:
--------
--- /work/SRC/openSUSE:Factory/azure-cli-iot/azure-cli-iot.changes      
2018-02-14 09:31:04.364674198 +0100
+++ /work/SRC/openSUSE:Factory/.azure-cli-iot.new/azure-cli-iot.changes 
2018-05-13 16:02:36.587706413 +0200
@@ -1,0 +2,7 @@
+Thu Apr 19 09:04:04 UTC 2018 - [email protected]
+
+- New upstream release
+  + Version 0.1.19
+- Move LICENSE.txt from %doc to %license section
+
+-------------------------------------------------------------------

Old:
----
  azure-cli-iot-0.1.16.tar.gz

New:
----
  azure-cli-iot-0.1.19.tar.gz

++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

Other differences:
------------------
++++++ azure-cli-iot.spec ++++++
--- /var/tmp/diff_new_pack.TxB2zC/_old  2018-05-13 16:02:37.715665261 +0200
+++ /var/tmp/diff_new_pack.TxB2zC/_new  2018-05-13 16:02:37.719665115 +0200
@@ -17,7 +17,7 @@
 
 
 Name:           azure-cli-iot
-Version:        0.1.16
+Version:        0.1.19
 Release:        0
 Summary:        Microsoft Azure CLI 'iot' Command Module
 License:        MIT
@@ -66,7 +66,8 @@
 
 %files
 %defattr(-,root,root,-)
-%doc HISTORY.rst LICENSE.txt README.rst
+%doc HISTORY.rst README.rst
+%license LICENSE.txt
 %{python3_sitelib}/azure/cli/command_modules/iot
 %{python3_sitelib}/azure_cli_iot-*.egg-info
 

++++++ azure-cli-iot-0.1.16.tar.gz -> azure-cli-iot-0.1.19.tar.gz ++++++
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' old/azure-cli-iot-0.1.16/HISTORY.rst 
new/azure-cli-iot-0.1.19/HISTORY.rst
--- old/azure-cli-iot-0.1.16/HISTORY.rst        2018-01-05 20:41:15.000000000 
+0100
+++ new/azure-cli-iot-0.1.19/HISTORY.rst        2018-04-06 19:33:13.000000000 
+0200
@@ -3,6 +3,22 @@
 Release History
 ===============
 
+0.1.19
+++++++
+
+* `sdist` is now compatible with wheel 0.31.0
+
+0.1.18
+++++++
+* Support Autorest 3.0 based SDKs
+
+0.1.17
+++++++
+* iot dps access policy create/update: Fixes issue where the command would 
occasionally return a 'not found' error on success. Added `--no-wait` support.
+* iot dps linked-hub create/update: Fixes issue where the command would 
occasionally return a 'not found' error on success. Added `--no-wait` support.
+* iot hub create: Allow specifying numbers of partitions during creation.
+* Minor fixes.
+
 0.1.16
 ++++++
 * Added support for device provisioning service
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' old/azure-cli-iot-0.1.16/PKG-INFO 
new/azure-cli-iot-0.1.19/PKG-INFO
--- old/azure-cli-iot-0.1.16/PKG-INFO   2018-01-05 20:42:07.000000000 +0100
+++ new/azure-cli-iot-0.1.19/PKG-INFO   2018-04-06 19:33:52.000000000 +0200
@@ -1,6 +1,6 @@
 Metadata-Version: 1.1
 Name: azure-cli-iot
-Version: 0.1.16
+Version: 0.1.19
 Summary: Microsoft Azure Command-Line Tools IoT Command Module
 Home-page: https://github.com/Azure/azure-cli
 Author: Microsoft Corporation
@@ -21,6 +21,22 @@
         Release History
         ===============
         
+        0.1.19
+        ++++++
+        
+        * `sdist` is now compatible with wheel 0.31.0
+        
+        0.1.18
+        ++++++
+        * Support Autorest 3.0 based SDKs
+        
+        0.1.17
+        ++++++
+        * iot dps access policy create/update: Fixes issue where the command 
would occasionally return a 'not found' error on success. Added `--no-wait` 
support.
+        * iot dps linked-hub create/update: Fixes issue where the command 
would occasionally return a 'not found' error on success. Added `--no-wait` 
support.
+        * iot hub create: Allow specifying numbers of partitions during 
creation.
+        * Minor fixes.
+        
         0.1.16
         ++++++
         * Added support for device provisioning service
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' 
old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/__init__.py 
new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/__init__.py
--- old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/__init__.py  
2018-01-05 20:41:15.000000000 +0100
+++ new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/__init__.py  
2018-04-06 19:33:13.000000000 +0200
@@ -3,16 +3,35 @@
 # Licensed under the MIT License. See License.txt in the project root for 
license information.
 # 
--------------------------------------------------------------------------------------------
 
+from knack.events import EVENT_INVOKER_POST_PARSE_ARGS
+from knack.log import get_logger
 from azure.cli.core import AzCommandsLoader
-
+from azure.cli.core.commands import CliCommandType
 import azure.cli.command_modules.iot._help  # pylint: disable=unused-import
+from azure.cli.core.extension import extension_exists
+
+
+def handler(ctx, **kwargs):
+    cmd = kwargs.get('command', None)
+    if cmd and cmd.startswith('iot'):
+        if not extension_exists('azure-cli-iot-ext'):
+            ran_before = ctx.config.getboolean('iot', 'first_run', 
fallback=False)
+            if not ran_before:
+                extension_text = """
+Comprehensive IoT data-plane functionality is available
+in the Azure IoT CLI Extension. For more info and install guide
+go to https://github.com/Azure/azure-iot-cli-extension
+"""
+                logger = get_logger(__name__)
+                logger.warning(extension_text)
+                ctx.config.set_value('iot', 'first_run', 'yes')
 
 
 class IoTCommandsLoader(AzCommandsLoader):
 
     def __init__(self, cli_ctx=None):
-        from azure.cli.core.commands import CliCommandType
         iot_custom = 
CliCommandType(operations_tmpl='azure.cli.command_modules.iot.custom#{}')
+        cli_ctx.register_event(EVENT_INVOKER_POST_PARSE_ARGS, handler)
         super(IoTCommandsLoader, self).__init__(cli_ctx=cli_ctx,
                                                 custom_command_type=iot_custom,
                                                 
min_profile='2017-03-10-profile')
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' 
old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/_help.py 
new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/_help.py
--- old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/_help.py     
2018-01-05 20:41:15.000000000 +0100
+++ new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/_help.py     
2018-04-06 19:33:13.000000000 +0200
@@ -79,7 +79,7 @@
     examples:
         - name: Update Allocation Policy to 'GeoLatency' of an Azure IoT Hub 
device provisioning service 'MyDps'
           text: >
-            az iot dps delete --name MyDps --resource-group MyResourceGroup 
--set properties.allocationPolicy="GeoLatency"
+            az iot dps update --name MyDps --resource-group MyResourceGroup 
--set properties.allocationPolicy="GeoLatency"
 """
 
 helps['iot dps access-policy'] = """
@@ -368,9 +368,10 @@
         - name: Create an IoT Hub with the free pricing tier F1, in the region 
of the resource group.
           text: >
             az iot hub create --resource-group MyResourceGroup --name MyIotHub
-        - name: Create an IoT Hub with the standard pricing tier S1, in the 
'westus' region.
+        - name: Create an IoT Hub with the standard pricing tier S1 and 4 
partitions, in the 'westus' region.
           text: >
             az iot hub create --resource-group MyResourceGroup --name MyIotHub 
--sku S1 --location westus
+            --partition-count 4
 """
 
 helps['iot hub show'] = """
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' 
old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/_params.py 
new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/_params.py
--- old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/_params.py   
2018-01-05 20:41:15.000000000 +0100
+++ new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/_params.py   
2018-04-06 19:33:13.000000000 +0200
@@ -54,14 +54,14 @@
     with self.argument_context('iot dps access-policy create') as c:
         c.argument('rights', options_list=['--rights', '-r'], nargs='+',
                    arg_type=get_enum_type(AccessRightsDescription),
-                   help='Access rights for the IoT provisioning service. Use 
space separated list for multiple rights.')
+                   help='Access rights for the IoT provisioning service. Use 
space-separated list for multiple rights.')
         c.argument('primary_key', help='Primary SAS key value.')
         c.argument('secondary_key', help='Secondary SAS key value.')
 
     with self.argument_context('iot dps access-policy update') as c:
         c.argument('rights', options_list=['--rights', '-r'], nargs='+',
                    arg_type=get_enum_type(AccessRightsDescription),
-                   help='Access rights for the IoT provisioning service. Use 
space separated list for multiple rights.')
+                   help='Access rights for the IoT provisioning service. Use 
space-separated list for multiple rights.')
         c.argument('primary_key', help='Primary SAS key value.')
         c.argument('secondary_key', help='Secondary SAS key value.')
 
@@ -125,7 +125,7 @@
                    help='Shared access policy name.')
         permission_values = ', '.join([x.value for x in SimpleAccessRights])
         c.argument('permissions', nargs='*', 
validator=validate_policy_permissions, type=str.lower,
-                   help='Permissions of shared access policy. Use space 
separated list for multiple permissions. '
+                   help='Permissions of shared access policy. Use 
space-separated list for multiple permissions. '
                         'Possible values: {}'.format(permission_values))
 
     with self.argument_context('iot hub job') as c:
@@ -140,6 +140,7 @@
                         'Note that only one free IoT hub instance is allowed 
in each '
                         'subscription. Exception will be thrown if free 
instances exceed one.')
         c.argument('unit', help='Units in your IoT Hub.', type=int)
+        c.argument('partition_count', help='The number of partitions for 
device-to-cloud messages.', type=int)
 
     with self.argument_context('iot hub show-connection-string') as c:
         c.argument('policy_name', help='Shared access policy to use.')
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' 
old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/commands.py 
new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/commands.py
--- old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/commands.py  
2018-01-05 20:41:15.000000000 +0100
+++ new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/commands.py  
2018-04-06 19:33:13.000000000 +0200
@@ -45,17 +45,17 @@
     with self.command_group('iot dps access-policy', 
client_factory=iot_service_provisioning_factory) as g:
         g.custom_command('list', 'iot_dps_access_policy_list')
         g.custom_command('show', 'iot_dps_access_policy_get')
-        g.custom_command('create', 'iot_dps_access_policy_create')
-        g.custom_command('update', 'iot_dps_access_policy_update')
-        g.custom_command('delete', 'iot_dps_access_policy_delete')
+        g.custom_command('create', 'iot_dps_access_policy_create', 
supports_no_wait=True)
+        g.custom_command('update', 'iot_dps_access_policy_update', 
supports_no_wait=True)
+        g.custom_command('delete', 'iot_dps_access_policy_delete', 
supports_no_wait=True)
 
     # iot dps linked-hub commands
     with self.command_group('iot dps linked-hub', 
client_factory=iot_service_provisioning_factory) as g:
         g.custom_command('list', 'iot_dps_linked_hub_list')
         g.custom_command('show', 'iot_dps_linked_hub_get')
-        g.custom_command('create', 'iot_dps_linked_hub_create')
-        g.custom_command('update', 'iot_dps_linked_hub_update')
-        g.custom_command('delete', 'iot_dps_linked_hub_delete')
+        g.custom_command('create', 'iot_dps_linked_hub_create', 
supports_no_wait=True)
+        g.custom_command('update', 'iot_dps_linked_hub_update', 
supports_no_wait=True)
+        g.custom_command('delete', 'iot_dps_linked_hub_delete', 
supports_no_wait=True)
 
     # iot dps certificate commands
     with self.command_group('iot dps certificate', 
client_factory=iot_service_provisioning_factory) as g:
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' 
old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/custom.py 
new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/custom.py
--- old/azure-cli-iot-0.1.16/azure/cli/command_modules/iot/custom.py    
2018-01-05 20:41:15.000000000 +0100
+++ new/azure-cli-iot-0.1.19/azure/cli/command_modules/iot/custom.py    
2018-04-06 19:33:13.000000000 +0200
@@ -7,14 +7,16 @@
 from __future__ import print_function
 from os.path import exists
 from enum import Enum
-from knack.config import CLIConfig
 from knack.util import CLIError
-from knack.log import get_logger
+from azure.cli.core.commands import LongRunningOperation
 
-from azure.mgmt.iothub.models.iot_hub_client_enums import IotHubSku, 
AccessRights
-from azure.mgmt.iothub.models.iot_hub_description import IotHubDescription
-from azure.mgmt.iothub.models.iot_hub_sku_info import IotHubSkuInfo
-from azure.mgmt.iothub.models.shared_access_signature_authorization_rule 
import SharedAccessSignatureAuthorizationRule
+from azure.mgmt.iothub.models import (IotHubSku,
+                                      AccessRights,
+                                      IotHubDescription,
+                                      IotHubSkuInfo,
+                                      SharedAccessSignatureAuthorizationRule,
+                                      IotHubProperties,
+                                      EventHubProperties)
 
 from azure.mgmt.iothubprovisioningservices.models import 
(ProvisioningServiceDescription,
                                                           
IotDpsPropertiesDescription,
@@ -28,28 +30,11 @@
 from 
azure.cli.command_modules.iot.mgmt_iot_hub_device.lib.models.device_description 
import DeviceDescription
 from 
azure.cli.command_modules.iot.mgmt_iot_hub_device.lib.models.x509_thumbprint 
import X509Thumbprint
 from azure.cli.command_modules.iot.sas_token_auth import SasTokenAuthentication
-from azure.cli.core.extension import extension_exists
-from azure.cli.core._environment import get_config_dir
+from azure.cli.core.util import sdk_no_wait
 
 from ._client_factory import resource_service_factory
 from ._utils import create_self_signed_certificate, open_certificate
 
-logger = get_logger(__name__)
-
-
-# IoT Extension run once awareness
-if not extension_exists('azure_cli_iot_ext'):
-    config = CLIConfig(get_config_dir())
-    ran_before = config.getboolean('iot', 'first_run', fallback=False)
-    if not ran_before:
-        extension_text = """
-                         Comprehensive IoT data-plane functionality is 
available
-                         in the Azure IoT CLI Extension. For more info and 
install guide
-                         go to https://github.com/Azure/azure-iot-cli-extension
-                         """
-        logger.warning(extension_text)
-        config.set_value('iot', 'first_run', 'yes')
-
 
 # CUSTOM TYPE
 class KeyType(Enum):
@@ -60,7 +45,7 @@
 # This is a work around to simplify the permission parameter for access policy 
creation, and also align with the other
 # command modules.
 # The original AccessRights enum is a combination of below four basic access 
rights.
-# In order to avoid asking for comma & space separated string from user, a 
space separated list is supported for
+# In order to avoid asking for comma- & space-separated strings from the user, 
a space-separated list is supported for
 # assigning multiple permissions.
 # The underlying IoT SDK should handle this. However it isn't right now. 
Remove this after it is fixed in IoT SDK.
 class SimpleAccessRights(Enum):
@@ -111,7 +96,7 @@
     return client.iot_dps_resource.list_keys_for_key_name(dps_name, 
access_policy_name, resource_group_name)
 
 
-def iot_dps_access_policy_create(client, dps_name, resource_group_name, 
access_policy_name, rights, primary_key=None, secondary_key=None):
+def iot_dps_access_policy_create(cmd, client, dps_name, resource_group_name, 
access_policy_name, rights, primary_key=None, secondary_key=None, 
no_wait=False):
     dps_access_policies = []
     dps_access_policies.extend(iot_dps_access_policy_list(client, dps_name, 
resource_group_name))
     if _is_policy_existed(dps_access_policies, access_policy_name):
@@ -125,15 +110,18 @@
     dps_property = IotDpsPropertiesDescription(None, None, 
dps.properties.iot_hubs, dps.properties.allocation_policy, dps_access_policies)
     dps_description = ProvisioningServiceDescription(dps.location, 
dps_property, dps.sku)
 
-    client.iot_dps_resource.create_or_update(resource_group_name, dps_name, 
dps_description)
+    if no_wait:
+        return client.iot_dps_resource.create_or_update(resource_group_name, 
dps_name, dps_description)
+    
LongRunningOperation(cmd.cli_ctx)(client.iot_dps_resource.create_or_update(resource_group_name,
 dps_name, dps_description))
     return iot_dps_access_policy_get(client, dps_name, resource_group_name, 
access_policy_name)
 
 
-def iot_dps_access_policy_update(client, dps_name, resource_group_name, 
access_policy_name, primary_key=None, secondary_key=None, rights=None):
+def iot_dps_access_policy_update(cmd, client, dps_name, resource_group_name, 
access_policy_name, primary_key=None, secondary_key=None, rights=None, 
no_wait=False):
     dps_access_policies = []
     dps_access_policies.extend(iot_dps_access_policy_list(client, dps_name, 
resource_group_name))
+
     if not _is_policy_existed(dps_access_policies, access_policy_name):
-        raise CLIError("Access policy {0} doesn't 
existed.".format(access_policy_name))
+        raise CLIError("Access policy {0} doesn't 
exist.".format(access_policy_name))
 
     for policy in dps_access_policies:
         if policy.key_name == access_policy_name:
@@ -148,11 +136,13 @@
     dps_property = IotDpsPropertiesDescription(None, None, 
dps.properties.iot_hubs, dps.properties.allocation_policy, dps_access_policies)
     dps_description = ProvisioningServiceDescription(dps.location, 
dps_property, dps.sku)
 
-    client.iot_dps_resource.create_or_update(resource_group_name, dps_name, 
dps_description)
+    if no_wait:
+        return client.iot_dps_resource.create_or_update(resource_group_name, 
dps_name, dps_description)
+    
LongRunningOperation(cmd.cli_ctx)(client.iot_dps_resource.create_or_update(resource_group_name,
 dps_name, dps_description))
     return iot_dps_access_policy_get(client, dps_name, resource_group_name, 
access_policy_name)
 
 
-def iot_dps_access_policy_delete(client, dps_name, resource_group_name, 
access_policy_name):
+def iot_dps_access_policy_delete(cmd, client, dps_name, resource_group_name, 
access_policy_name, no_wait=False):
     dps_access_policies = []
     dps_access_policies.extend(iot_dps_access_policy_list(client, dps_name, 
resource_group_name))
     if not _is_policy_existed(dps_access_policies, access_policy_name):
@@ -163,7 +153,9 @@
     dps_property = IotDpsPropertiesDescription(None, None, 
dps.properties.iot_hubs, dps.properties.allocation_policy, updated_policies)
     dps_description = ProvisioningServiceDescription(dps.location, 
dps_property, dps.sku)
 
-    client.iot_dps_resource.create_or_update(resource_group_name, dps_name, 
dps_description)
+    if no_wait:
+        return client.iot_dps_resource.create_or_update(resource_group_name, 
dps_name, dps_description)
+    
LongRunningOperation(cmd.cli_ctx)(client.iot_dps_resource.create_or_update(resource_group_name,
 dps_name, dps_description))
     return iot_dps_access_policy_list(client, dps_name, resource_group_name)
 
 
@@ -181,7 +173,7 @@
     raise CLIError("Linked hub '{0}' does not exist. Use 'iot dps linked-hub 
show to see all linked hubs.".format(linked_hub))
 
 
-def iot_dps_linked_hub_create(client, dps_name, resource_group_name, 
connection_string, location, apply_allocation_policy=None, 
allocation_weight=None):
+def iot_dps_linked_hub_create(cmd, client, dps_name, resource_group_name, 
connection_string, location, apply_allocation_policy=None, 
allocation_weight=None, no_wait=False):
     dps_linked_hubs = []
     dps_linked_hubs.extend(iot_dps_linked_hub_list(client, dps_name, 
resource_group_name))
     dps_linked_hubs.append(IotHubDefinitionDescription(connection_string, 
location, apply_allocation_policy, allocation_weight))
@@ -190,11 +182,13 @@
     dps_property = IotDpsPropertiesDescription(None, None, dps_linked_hubs, 
dps.properties.allocation_policy, dps.properties.authorization_policies)
     dps_description = ProvisioningServiceDescription(dps.location, 
dps_property, dps.sku)
 
-    client.iot_dps_resource.create_or_update(resource_group_name, dps_name, 
dps_description)
+    if no_wait:
+        return client.iot_dps_resource.create_or_update(resource_group_name, 
dps_name, dps_description)
+    
LongRunningOperation(cmd.cli_ctx)(client.iot_dps_resource.create_or_update(resource_group_name,
 dps_name, dps_description))
     return iot_dps_linked_hub_list(client, dps_name, resource_group_name)
 
 
-def iot_dps_linked_hub_update(client, dps_name, resource_group_name, 
linked_hub, apply_allocation_policy=None, allocation_weight=None):
+def iot_dps_linked_hub_update(cmd, client, dps_name, resource_group_name, 
linked_hub, apply_allocation_policy=None, allocation_weight=None, 
no_wait=False):
     dps_linked_hubs = []
     dps_linked_hubs.extend(iot_dps_linked_hub_list(client, dps_name, 
resource_group_name))
     if not _is_linked_hub_existed(dps_linked_hubs, linked_hub):
@@ -211,11 +205,13 @@
     dps_property = IotDpsPropertiesDescription(None, None, dps_linked_hubs, 
dps.properties.allocation_policy, dps.properties.authorization_policies)
     dps_description = ProvisioningServiceDescription(dps.location, 
dps_property, dps.sku)
 
-    client.iot_dps_resource.create_or_update(resource_group_name, dps_name, 
dps_description)
+    if no_wait:
+        return client.iot_dps_resource.create_or_update(resource_group_name, 
dps_name, dps_description)
+    
LongRunningOperation(cmd.cli_ctx)(client.iot_dps_resource.create_or_update(resource_group_name,
 dps_name, dps_description))
     return iot_dps_linked_hub_get(client, dps_name, resource_group_name, 
linked_hub)
 
 
-def iot_dps_linked_hub_delete(client, dps_name, resource_group_name, 
linked_hub):
+def iot_dps_linked_hub_delete(cmd, client, dps_name, resource_group_name, 
linked_hub, no_wait=False):
     dps_linked_hubs = []
     dps_linked_hubs.extend(iot_dps_linked_hub_list(client, dps_name, 
resource_group_name))
     if not _is_linked_hub_existed(dps_linked_hubs, linked_hub):
@@ -226,7 +222,9 @@
     dps_property = IotDpsPropertiesDescription(None, None, updated_hub, 
dps.properties.allocation_policy, dps.properties.authorization_policies)
     dps_description = ProvisioningServiceDescription(dps.location, 
dps_property, dps.sku)
 
-    client.iot_dps_resource.create_or_update(resource_group_name, dps_name, 
dps_description)
+    if no_wait:
+        return client.iot_dps_resource.create_or_update(resource_group_name, 
dps_name, dps_description)
+    
LongRunningOperation(cmd.cli_ctx)(client.iot_dps_resource.create_or_update(resource_group_name,
 dps_name, dps_description))
     return iot_dps_linked_hub_list(client, dps_name, resource_group_name)
 
 
@@ -335,12 +333,17 @@
     return client.certificates.verify(resource_group_name, hub_name, 
certificate_name, etag, certificate)
 
 
-def iot_hub_create(cmd, client, hub_name, resource_group_name, location=None, 
sku=IotHubSku.f1.value, unit=1):
+def iot_hub_create(cmd, client, hub_name, resource_group_name, location=None, 
sku=IotHubSku.f1.value, unit=1, partition_count=2):
     cli_ctx = cmd.cli_ctx
     _check_name_availability(client.iot_hub_resource, hub_name)
     location = _ensure_location(cli_ctx, resource_group_name, location)
+    sku = IotHubSkuInfo(name=sku, capacity=unit)
+
+    event_hub_dic = {}
+    event_hub_dic['events'] = EventHubProperties(1, partition_count)
+    properties = IotHubProperties(None, None, event_hub_dic)
     hub_description = IotHubDescription(location, 
client.iot_hub_resource.config.subscription_id, resource_group_name,
-                                        IotHubSkuInfo(name=sku, capacity=unit))
+                                        sku, None, None, properties)
     return client.iot_hub_resource.create_or_update(resource_group_name, 
hub_name, hub_description)
 
 
@@ -564,7 +567,7 @@
 # pylint: disable=inconsistent-return-statements
 def iot_device_receive_message(client, hub_name, device_id, 
resource_group_name=None, lock_timeout=60):
     device_client = _get_device_client(client, resource_group_name, hub_name, 
device_id)
-    result = device_client.receive_message(device_id, lock_timeout, raw=True)
+    result = sdk_no_wait(True, device_client.receive_message, device_id, 
lock_timeout)
     if result is not None and result.response.status_code == 200:
         return {
             'ack': result.headers['iothub-ack'],
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' old/azure-cli-iot-0.1.16/azure_cli_iot.egg-info/PKG-INFO 
new/azure-cli-iot-0.1.19/azure_cli_iot.egg-info/PKG-INFO
--- old/azure-cli-iot-0.1.16/azure_cli_iot.egg-info/PKG-INFO    2018-01-05 
20:42:07.000000000 +0100
+++ new/azure-cli-iot-0.1.19/azure_cli_iot.egg-info/PKG-INFO    2018-04-06 
19:33:52.000000000 +0200
@@ -1,6 +1,6 @@
 Metadata-Version: 1.1
 Name: azure-cli-iot
-Version: 0.1.16
+Version: 0.1.19
 Summary: Microsoft Azure Command-Line Tools IoT Command Module
 Home-page: https://github.com/Azure/azure-cli
 Author: Microsoft Corporation
@@ -21,6 +21,22 @@
         Release History
         ===============
         
+        0.1.19
+        ++++++
+        
+        * `sdist` is now compatible with wheel 0.31.0
+        
+        0.1.18
+        ++++++
+        * Support Autorest 3.0 based SDKs
+        
+        0.1.17
+        ++++++
+        * iot dps access policy create/update: Fixes issue where the command 
would occasionally return a 'not found' error on success. Added `--no-wait` 
support.
+        * iot dps linked-hub create/update: Fixes issue where the command 
would occasionally return a 'not found' error on success. Added `--no-wait` 
support.
+        * iot hub create: Allow specifying numbers of partitions during 
creation.
+        * Minor fixes.
+        
         0.1.16
         ++++++
         * Added support for device provisioning service
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' 
'--exclude=.svnignore' old/azure-cli-iot-0.1.16/setup.py 
new/azure-cli-iot-0.1.19/setup.py
--- old/azure-cli-iot-0.1.16/setup.py   2018-01-05 20:41:15.000000000 +0100
+++ new/azure-cli-iot-0.1.19/setup.py   2018-04-06 19:33:13.000000000 +0200
@@ -14,7 +14,7 @@
     logger.warn("Wheel is not available, disabling bdist_wheel hook")
     cmdclass = {}
 
-VERSION = "0.1.16"
+VERSION = "0.1.19"
 # The full list of classifiers is available at
 # https://pypi.python.org/pypi?%3Aaction=list_classifiers
 CLASSIFIERS = [


Reply via email to