Skip to content

Commit

Permalink
Update codegen files (#570)
Browse files Browse the repository at this point in the history
Code generated after smithy model updated to v2.
  • Loading branch information
sfod authored Mar 21, 2024
1 parent b3cfc7f commit 5683a80
Show file tree
Hide file tree
Showing 2 changed files with 23 additions and 41 deletions.
16 changes: 8 additions & 8 deletions awsiot/iotjobs.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,10 +34,10 @@ def publish_describe_job_execution(self, request, qos):
request is successfully published. The Future's result will be an
exception if the request cannot be published.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.job_id:
raise ValueError("request.job_id is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

return self._publish_operation(
topic='$aws/things/{0.thing_name}/jobs/{0.job_id}/get'.format(request),
Expand Down Expand Up @@ -111,10 +111,10 @@ def publish_update_job_execution(self, request, qos):
request is successfully published. The Future's result will be an
exception if the request cannot be published.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.job_id:
raise ValueError("request.job_id is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

return self._publish_operation(
topic='$aws/things/{0.thing_name}/jobs/{0.job_id}/update'.format(request),
Expand Down Expand Up @@ -143,10 +143,10 @@ def subscribe_to_describe_job_execution_accepted(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.job_id:
raise ValueError("request.job_id is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -179,10 +179,10 @@ def subscribe_to_describe_job_execution_rejected(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.job_id:
raise ValueError("request.job_id is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down
48 changes: 15 additions & 33 deletions awsiot/iotshadow.py
Original file line number Diff line number Diff line change
Expand Up @@ -195,10 +195,10 @@ def subscribe_to_delete_named_shadow_accepted(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -231,10 +231,10 @@ def subscribe_to_delete_named_shadow_rejected(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -335,10 +335,10 @@ def subscribe_to_get_named_shadow_accepted(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -371,10 +371,10 @@ def subscribe_to_get_named_shadow_rejected(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -475,10 +475,10 @@ def subscribe_to_named_shadow_delta_updated_events(self, request, qos, callback)
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -615,10 +615,10 @@ def subscribe_to_update_named_shadow_accepted(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -651,10 +651,10 @@ def subscribe_to_update_named_shadow_rejected(self, request, qos, callback):
to `unsubscribe()` to stop receiving messages. Note that messages
may arrive before the subscription is acknowledged.
"""
if not request.thing_name:
raise ValueError("request.thing_name is required")
if not request.shadow_name:
raise ValueError("request.shadow_name is required")
if not request.thing_name:
raise ValueError("request.thing_name is required")

if not callable(callback):
raise ValueError("callback is required")
Expand Down Expand Up @@ -765,10 +765,8 @@ def __init__(self, *args, **kwargs):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.client_token is not None:
payload['clientToken'] = self.client_token

return payload

class DeleteNamedShadowSubscriptionRequest(awsiot.ModeledClass):
Expand Down Expand Up @@ -826,10 +824,8 @@ def __init__(self, *args, **kwargs):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.client_token is not None:
payload['clientToken'] = self.client_token

return payload

class DeleteShadowResponse(awsiot.ModeledClass):
Expand Down Expand Up @@ -981,10 +977,8 @@ def __init__(self, *args, **kwargs):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.client_token is not None:
payload['clientToken'] = self.client_token

return payload

class GetNamedShadowSubscriptionRequest(awsiot.ModeledClass):
Expand Down Expand Up @@ -1042,10 +1036,8 @@ def __init__(self, *args, **kwargs):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.client_token is not None:
payload['clientToken'] = self.client_token

return payload

class GetShadowResponse(awsiot.ModeledClass):
Expand Down Expand Up @@ -1346,19 +1338,16 @@ def from_payload(cls, payload):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.desired_is_nullable is True:
payload['desired'] = self.desired
else:
if self.desired is not None:
payload['desired'] = self.desired

if self.reported_is_nullable is True:
payload['reported'] = self.reported
else:
if self.reported is not None:
payload['reported'] = self.reported

return payload

class ShadowStateWithDelta(awsiot.ModeledClass):
Expand Down Expand Up @@ -1554,16 +1543,12 @@ def __init__(self, *args, **kwargs):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.client_token is not None:
payload['clientToken'] = self.client_token

if self.state is not None:
payload['state'] = self.state.to_payload()

if self.version is not None:
payload['version'] = self.version

return payload

class UpdateNamedShadowSubscriptionRequest(awsiot.ModeledClass):
Expand Down Expand Up @@ -1627,16 +1612,12 @@ def __init__(self, *args, **kwargs):
def to_payload(self):
# type: () -> typing.Dict[str, typing.Any]
payload = {} # type: typing.Dict[str, typing.Any]

if self.client_token is not None:
payload['clientToken'] = self.client_token

if self.state is not None:
payload['state'] = self.state.to_payload()

if self.version is not None:
payload['version'] = self.version

return payload

class UpdateShadowResponse(awsiot.ModeledClass):
Expand Down Expand Up @@ -1717,3 +1698,4 @@ def __init__(self, *args, **kwargs):
# for backwards compatibility, read any arguments that used to be accepted by position
for key, val in zip(['thing_name'], args):
setattr(self, key, val)

0 comments on commit 5683a80

Please sign in to comment.