diff --git a/awsiot/__init__.py b/awsiot/__init__.py
new file mode 100644
index 00000000..32bd04a3
--- /dev/null
+++ b/awsiot/__init__.py
@@ -0,0 +1,4 @@
+__all__ = [
+    'iotjobs',
+    'iotshadow',
+]
diff --git a/awsiot/iotjobs.py b/awsiot/iotjobs.py
new file mode 100644
index 00000000..bb26a7e6
--- /dev/null
+++ b/awsiot/iotjobs.py
@@ -0,0 +1,620 @@
+# Copyright 2010-2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License").
+# You may not use this file except in compliance with the License.
+# A copy of the License is located at
+#
+#  http://aws.amazon.com/apache2.0
+#
+# or in the "license" file accompanying this file. This file is distributed
+# on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+# express or implied. See the License for the specific language governing
+# permissions and limitations under the License.
+
+# This file is generated
+
+# TODO:
+# - handle required fields from model differently?
+# - better type-checking of callback signatures (or even better remove callbacks from API)
+# - comments
+# - unsubscribe
+# - python2/3 compatibility https://docs.python.org/3/howto/pyporting.html
+
+import aws_crt.mqtt
+import concurrent.futures
+import datetime
+import json
+import typing
+import uuid
+
+class IotJobsClient(object):
+    def __init__(self, mqtt_connection):
+        # type: (aws_crt.mqtt.Connection) -> None
+        self.mqtt_connection = mqtt_connection # type: aws_crt.mqtt.Connection
+
+    def describe_job_execution(self, input):
+        # type: (DescribeJobExecutionRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/jobs/{0.job_id}/get'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/{0.job_id}/get/accepted'.format(input),
+                payload_class=DescribeJobExecutionResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/{0.job_id}/get/rejected'.format(input),
+                payload_class=RejectedError,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def get_job_executions_changed(self, input, handler):
+        # type: (GetJobExecutionsChangedRequest, JobExecutionsChangedEventsHandler) -> concurrent.futures.Future
+
+        if not handler.on_job_executions_changed:
+            raise ValueError("handler.on_job_executions_changed is required")
+
+        subscriptions = [
+            _SubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/notify'.format(input),
+                callback=handler.on_job_executions_changed,
+                payload_class=JobExecutionsChangedEvent,
+            ),
+        ]
+
+        return self._subscribe_operation(subscriptions)
+
+    def get_next_job_execution_changed(self, input, handler):
+        # type: (GetNextJobExecutionChangedRequest, NextJobExecutionChangedEventsHandler) -> concurrent.futures.Future
+
+        if not handler.on_next_job_execution_changed:
+            raise ValueError("handler.on_next_job_execution_changed is required")
+
+        subscriptions = [
+            _SubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/notify-next'.format(input),
+                callback=handler.on_next_job_execution_changed,
+                payload_class=NextJobExecutionChangedEvent,
+            ),
+        ]
+
+        return self._subscribe_operation(subscriptions)
+
+    def get_pending_job_executions(self, input):
+        # type: (GetPendingJobExecutionsRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/jobs/get'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/get/accepted'.format(input),
+                payload_class=GetPendingJobExecutionsResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/get/rejected'.format(input),
+                payload_class=RejectedError,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def start_next_pending_job_execution(self, input):
+        # type: (StartNextPendingJobExecutionRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/jobs/start-next'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/start-next/accepted'.format(input),
+                payload_class=StartDescribeJobExecutionResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/start-next/rejected'.format(input),
+                payload_class=RejectedError,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def update_job_execution(self, input):
+        # type: (UpdateJobExecutionRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/jobs/{0.job_id}/update'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/{0.job_id}/update/accepted'.format(input),
+                payload_class=UpdateJobExecutionResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/jobs/{0.job_id}/update/rejected'.format(input),
+                payload_class=RejectedError,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def _rpc_operation(self, pub_topic, input, subscriptions):
+        # type: (str, typing.Any, typing.List[_RpcSubscriptionInfo]) -> concurrent.futures.Future
+        """
+        Performs a 'Remote Procedure Call' style operation for an MQTT service.
+
+        Parameters:
+        pub_topic - Topic for request message.
+        input - Input object for request message.
+        subscriptions - List of _RpcSubscriptionInfos, one for each possible response.
+
+        Returns a Future that will contain the outcome of the operation.
+        A response from a non-error topic becomes a valid result in the Future.
+        A response from an error topic becomes an Exception in the Future.
+        Any other exception that occurs as part of the RPC becomes an exception in the Future.
+        """
+        if not input.client_token:
+            input.client_token = str(uuid.uuid4())
+        input_payload = input.to_payload()
+        input_json_payload = json.dumps(input_payload)
+
+        future = concurrent.futures.Future() # type: concurrent.futures.Future
+
+        suback_counter = ['suback'] * len(subscriptions)
+
+        # callback counts subacks, when last one is received the request is published.
+        def on_suback(packet_id):
+            try:
+                # count supacks by popping an entry out of this list
+                if suback_counter:
+                    suback_counter.pop()
+                    if not suback_counter:
+                        # all subscriptions succeeded, publish request
+                        self.mqtt_connection.publish(pub_topic, input_json_payload, 1, False, None)
+            except Exception as e:
+                future.set_exception(e)
+
+        for sub in subscriptions:
+            # callback transforms payload into appropriate class and delivers it to the future
+            def on_response(topic, json_payload):
+                try:
+                    payload = json.loads(json_payload)
+                    result = sub.payload_class.from_payload(payload)
+                    if sub.is_error:
+                        future.set_exception(result)
+                    else:
+                        future.set_result(result)
+                except Exception as e:
+                    future.set_exception(e)
+
+            self.mqtt_connection.subscribe(sub.topic, 1, on_response, on_suback)
+
+        return future
+
+    def _subscribe_operation(self, subscriptions):
+        # type: (typing.List[_SubscriptionInfo]) -> concurrent.futures.Future
+        """
+        Performs a 'Subscribe' style operation for an MQTT service.
+
+        Parameters:
+        subscriptions - List of _SubscriptionInfos, one for each possible response.
+
+        Returns a Future that will contain None when all subscriptions have been acknowledged by the server.
+        """
+
+        future = concurrent.futures.Future() # type: concurrent.futures.Future
+
+        # callback informs Future when all subacks received
+        suback_counter = ['suback'] * len(subscriptions)
+        def on_suback(packet_id):
+            # count supacks by popping an entry out of this list
+            if suback_counter:
+                suback_counter.pop()
+                if not suback_counter:
+                    # all subscriptions succeeded
+                    future.set_result(None)
+
+        for sub in subscriptions:
+            def callback_wrapper(topic, json_payload):
+                try:
+                    payload = json.loads(json_payload)
+                    event = sub.payload_class.from_payload(payload)
+                    sub.callback(event)
+                except:
+                    # can't deliver payload, invoke callback with None
+                    sub.callback(None)
+
+            self.mqtt_connection.subscribe(sub.topic, 1, callback_wrapper, on_suback)
+
+        return future
+
+T = typing.TypeVar('T')
+
+class _RpcSubscriptionInfo(object):
+    # type: typing.Generic[T]
+
+    def __init__(self, topic, payload_class, is_error):
+        # type: (str, typing.Type[T], bool) -> None
+        self.topic = topic # type: str
+        self.payload_class = payload_class # type: typing.Type[T]
+        self.is_error = is_error # type: bool
+
+class _SubscriptionInfo(object):
+    # type: typing.Generic[T]
+
+    def __init__(self, topic, callback, payload_class):
+        # type: (str, typing.Callable[[T], None], typing.Type[T]) -> None
+        self.topic = topic # type: str
+        self.callback = callback # type: typing.Callable[[T], None]
+        self.payload_class = payload_class # typing.Type[T]
+
+class DescribeJobExecutionRequest(object):
+    def __init__(self, client_token=None, execution_number=None, include_job_document=None, job_id=None, thing_name=None):
+        # type: (typing.Optional[str], typing.Optional[int], typing.Optional[bool], typing.Optional[str], typing.Optional[str]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.execution_number = execution_number # type: typing.Optional[int]
+        self.include_job_document = include_job_document # type: typing.Optional[bool]
+        self.job_id = job_id # type: typing.Optional[str]
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+    def to_payload(self):
+        # type: () -> typing.Dict[str, typing.Any]
+        payload = {} # type: typing.Dict[str, typing.Any]
+        if self.client_token:
+            payload['clientToken'] = self.client_token
+        if self.execution_number:
+            payload['executionNumber'] = self.execution_number
+        if self.include_job_document:
+            payload['includeJobDocument'] = self.include_job_document
+        return payload
+
+class DescribeJobExecutionResponse(object):
+    def __init__(self, client_token=None, execution=None, timestamp=None):
+        # type: (typing.Optional[str], typing.Optional[JobExecutionData], typing.Optional[datetime.datetime]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.execution = execution # type: typing.Optional[JobExecutionData]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> DescribeJobExecutionResponse
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('execution')
+        if val:
+            new.execution = JobExecutionData.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class GetJobExecutionsChangedRequest(object):
+    def __init__(self, thing_name=None):
+        # type: (typing.Optional[str]) -> None
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+class GetNextJobExecutionChangedRequest(object):
+    def __init__(self, thing_name=None):
+        # type: (typing.Optional[str]) -> None
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+class GetPendingJobExecutionsRequest(object):
+    def __init__(self, client_token=None, thing_name=None):
+        # type: (typing.Optional[str], typing.Optional[str]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+    def to_payload(self):
+        # type: () -> typing.Dict[str, typing.Any]
+        payload = {} # type: typing.Dict[str, typing.Any]
+        if self.client_token:
+            payload['clientToken'] = self.client_token
+        return payload
+
+class GetPendingJobExecutionsResponse(object):
+    def __init__(self, client_token=None, in_progress_jobs=None, queued_jobs=None, timestamp=None):
+        # type: (typing.Optional[str], typing.Optional[typing.List[JobExecutionSummary]], typing.Optional[typing.List[JobExecutionSummary]], typing.Optional[datetime.datetime]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.in_progress_jobs = in_progress_jobs # type: typing.Optional[typing.List[JobExecutionSummary]]
+        self.queued_jobs = queued_jobs # type: typing.Optional[typing.List[JobExecutionSummary]]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> GetPendingJobExecutionsResponse
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('inProgressJobs')
+        if val:
+            new.in_progress_jobs = [JobExecutionSummary.from_payload(i) for i in val]
+        val = payload.get('queuedJobs')
+        if val:
+            new.queued_jobs = [JobExecutionSummary.from_payload(i) for i in val]
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class JobExecutionData(object):
+    def __init__(self, execution_number=None, job_document=None, job_id=None, last_updated_at=None, queued_at=None, started_at=None, status=None, thing_name=None, version_number=None):
+        # type: (typing.Optional[int], typing.Optional[str], typing.Optional[str], typing.Optional[datetime.datetime], typing.Optional[datetime.datetime], typing.Optional[datetime.datetime], typing.Optional[str], typing.Optional[str], typing.Optional[int]) -> None
+        self.execution_number = execution_number # type: typing.Optional[int]
+        self.job_document = job_document # type: typing.Optional[str]
+        self.job_id = job_id # type: typing.Optional[str]
+        self.last_updated_at = last_updated_at # type: typing.Optional[datetime.datetime]
+        self.queued_at = queued_at # type: typing.Optional[datetime.datetime]
+        self.started_at = started_at # type: typing.Optional[datetime.datetime]
+        self.status = status # type: typing.Optional[str]
+        self.thing_name = thing_name # type: typing.Optional[str]
+        self.version_number = version_number # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> JobExecutionData
+        new = cls()
+        val = payload.get('executionNumber')
+        if val:
+            new.execution_number = val
+        val = payload.get('jobDocument')
+        if val:
+            new.job_document = val
+        val = payload.get('jobId')
+        if val:
+            new.job_id = val
+        val = payload.get('lastUpdatedAt')
+        if val:
+            new.last_updated_at = datetime.datetime.fromtimestamp(val)
+        val = payload.get('queuedAt')
+        if val:
+            new.queued_at = datetime.datetime.fromtimestamp(val)
+        val = payload.get('startedAt')
+        if val:
+            new.started_at = datetime.datetime.fromtimestamp(val)
+        val = payload.get('status')
+        if val:
+            new.status = val
+        val = payload.get('thingName')
+        if val:
+            new.thing_name = val
+        val = payload.get('versionNumber')
+        if val:
+            new.version_number = val
+        return new
+
+class JobExecutionState(object):
+    def __init__(self, status=None, status_details=None, version_number=None):
+        # type: (typing.Optional[str], typing.Optional[typing.Dict[str, str]], typing.Optional[int]) -> None
+        self.status = status # type: typing.Optional[str]
+        self.status_details = status_details # type: typing.Optional[typing.Dict[str, str]]
+        self.version_number = version_number # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> JobExecutionState
+        new = cls()
+        val = payload.get('status')
+        if val:
+            new.status = val
+        val = payload.get('statusDetails')
+        if val:
+            new.status_details = val
+        val = payload.get('versionNumber')
+        if val:
+            new.version_number = val
+        return new
+
+class JobExecutionSummary(object):
+    def __init__(self, execution_number=None, last_updated_at=None, queued_at=None, started_at=None):
+        # type: (typing.Optional[int], typing.Optional[datetime.datetime], typing.Optional[datetime.datetime], typing.Optional[datetime.datetime]) -> None
+        self.execution_number = execution_number # type: typing.Optional[int]
+        self.last_updated_at = last_updated_at # type: typing.Optional[datetime.datetime]
+        self.queued_at = queued_at # type: typing.Optional[datetime.datetime]
+        self.started_at = started_at # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> JobExecutionSummary
+        new = cls()
+        val = payload.get('executionNumber')
+        if val:
+            new.execution_number = val
+        val = payload.get('lastUpdatedAt')
+        if val:
+            new.last_updated_at = datetime.datetime.fromtimestamp(val)
+        val = payload.get('queuedAt')
+        if val:
+            new.queued_at = datetime.datetime.fromtimestamp(val)
+        val = payload.get('startedAt')
+        if val:
+            new.started_at = datetime.datetime.fromtimestamp(val)
+        return new
+
+class JobExecutionsChangedEvent(object):
+    def __init__(self, jobs=None, timestamp=None):
+        # type: (typing.Optional[JobExecutionsChangedJobs], typing.Optional[datetime.datetime]) -> None
+        self.jobs = jobs # type: typing.Optional[JobExecutionsChangedJobs]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> JobExecutionsChangedEvent
+        new = cls()
+        val = payload.get('jobs')
+        if val:
+            new.jobs = JobExecutionsChangedJobs.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class JobExecutionsChangedEventsHandler:
+    def __init__(self):
+        self.on_job_executions_changed = None # type: typing.Callable[[JobExecutionsChangedEvent], None]
+
+class JobExecutionsChangedJobs(object):
+    def __init__(self, job_execution_state=None):
+        # type: (typing.Optional[typing.List[JobExecutionSummary]]) -> None
+        self.job_execution_state = job_execution_state # type: typing.Optional[typing.List[JobExecutionSummary]]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> JobExecutionsChangedJobs
+        new = cls()
+        val = payload.get('JobExecutionState')
+        if val:
+            new.job_execution_state = [JobExecutionSummary.from_payload(i) for i in val]
+        return new
+
+class NextJobExecutionChangedEvent(object):
+    def __init__(self, execution=None, timestamp=None):
+        # type: (typing.Optional[JobExecutionData], typing.Optional[datetime.datetime]) -> None
+        self.execution = execution # type: typing.Optional[JobExecutionData]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> NextJobExecutionChangedEvent
+        new = cls()
+        val = payload.get('execution')
+        if val:
+            new.execution = JobExecutionData.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class NextJobExecutionChangedEventsHandler:
+    def __init__(self):
+        self.on_next_job_execution_changed = None # type: typing.Callable[[NextJobExecutionChangedEvent], None]
+
+class RejectedError(Exception):
+    def __init__(self, client_token=None, code=None, execution_state=None, message=None, timestamp=None):
+        # type: (typing.Optional[str], typing.Optional[str], typing.Optional[JobExecutionState], typing.Optional[str], typing.Optional[datetime.datetime]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.code = code # type: typing.Optional[str]
+        self.execution_state = execution_state # type: typing.Optional[JobExecutionState]
+        self.message = message # type: typing.Optional[str]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> RejectedError
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('code')
+        if val:
+            new.code = val
+        val = payload.get('executionState')
+        if val:
+            new.execution_state = JobExecutionState.from_payload(val)
+        val = payload.get('message')
+        if val:
+            new.message = val
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class StartDescribeJobExecutionResponse(object):
+    def __init__(self, client_token=None, execution=None, timestamp=None):
+        # type: (typing.Optional[str], typing.Optional[JobExecutionData], typing.Optional[datetime.datetime]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.execution = execution # type: typing.Optional[JobExecutionData]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> StartDescribeJobExecutionResponse
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('execution')
+        if val:
+            new.execution = JobExecutionData.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class StartNextPendingJobExecutionRequest(object):
+    def __init__(self, client_token=None, status_details=None, step_timeout_in_minutes=None, thing_name=None):
+        # type: (typing.Optional[str], typing.Optional[typing.Dict[str, str]], typing.Optional[int], typing.Optional[str]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.status_details = status_details # type: typing.Optional[typing.Dict[str, str]]
+        self.step_timeout_in_minutes = step_timeout_in_minutes # type: typing.Optional[int]
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+    def to_payload(self):
+        # type: () -> typing.Dict[str, typing.Any]
+        payload = {} # type: typing.Dict[str, typing.Any]
+        if self.client_token:
+            payload['clientToken'] = self.client_token
+        if self.status_details:
+            payload['statusDetails'] = self.status_details
+        if self.step_timeout_in_minutes:
+            payload['stepTimeoutInMinutes'] = self.step_timeout_in_minutes
+        return payload
+
+class UpdateJobExecutionRequest(object):
+    def __init__(self, client_token=None, execution_number=None, expected_version=None, include_job_document=None, include_job_execution_state=None, job_id=None, status=None, status_details=None, thing_name=None):
+        # type: (typing.Optional[str], typing.Optional[int], typing.Optional[int], typing.Optional[bool], typing.Optional[bool], typing.Optional[str], typing.Optional[str], typing.Optional[typing.Dict[str, str]], typing.Optional[str]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.execution_number = execution_number # type: typing.Optional[int]
+        self.expected_version = expected_version # type: typing.Optional[int]
+        self.include_job_document = include_job_document # type: typing.Optional[bool]
+        self.include_job_execution_state = include_job_execution_state # type: typing.Optional[bool]
+        self.job_id = job_id # type: typing.Optional[str]
+        self.status = status # type: typing.Optional[str]
+        self.status_details = status_details # type: typing.Optional[typing.Dict[str, str]]
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+    def to_payload(self):
+        # type: () -> typing.Dict[str, typing.Any]
+        payload = {} # type: typing.Dict[str, typing.Any]
+        if self.client_token:
+            payload['clientToken'] = self.client_token
+        if self.execution_number:
+            payload['executionNumber'] = self.execution_number
+        if self.expected_version:
+            payload['expectedVersion'] = self.expected_version
+        if self.include_job_document:
+            payload['includeJobDocument'] = self.include_job_document
+        if self.include_job_execution_state:
+            payload['includeJobExecutionState'] = self.include_job_execution_state
+        if self.status:
+            payload['status'] = self.status
+        if self.status_details:
+            payload['statusDetails'] = self.status_details
+        return payload
+
+class UpdateJobExecutionResponse(object):
+    def __init__(self, client_token=None, execution_state=None, job_document=None, timestamp=None):
+        # type: (typing.Optional[str], typing.Optional[JobExecutionState], typing.Optional[str], typing.Optional[datetime.datetime]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.execution_state = execution_state # type: typing.Optional[JobExecutionState]
+        self.job_document = job_document # type: typing.Optional[str]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> UpdateJobExecutionResponse
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('executionState')
+        if val:
+            new.execution_state = JobExecutionState.from_payload(val)
+        val = payload.get('jobDocument')
+        if val:
+            new.job_document = val
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
diff --git a/awsiot/iotshadow.py b/awsiot/iotshadow.py
new file mode 100644
index 00000000..0f549c40
--- /dev/null
+++ b/awsiot/iotshadow.py
@@ -0,0 +1,514 @@
+# Copyright 2010-2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License").
+# You may not use this file except in compliance with the License.
+# A copy of the License is located at
+#
+#  http://aws.amazon.com/apache2.0
+#
+# or in the "license" file accompanying this file. This file is distributed
+# on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+# express or implied. See the License for the specific language governing
+# permissions and limitations under the License.
+
+# This file is generated
+
+# TODO:
+# - handle required fields from model differently?
+# - better type-checking of callback signatures (or even better remove callbacks from API)
+# - comments
+# - unsubscribe
+# - python2/3 compatibility https://docs.python.org/3/howto/pyporting.html
+
+import aws_crt.mqtt
+import concurrent.futures
+import datetime
+import json
+import typing
+import uuid
+
+class IotShadowClient(object):
+    def __init__(self, mqtt_connection):
+        # type: (aws_crt.mqtt.Connection) -> None
+        self.mqtt_connection = mqtt_connection # type: aws_crt.mqtt.Connection
+
+    def delete_shadow(self, input):
+        # type: (DeleteShadowRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/shadow/delete'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/delete/accepted'.format(input),
+                payload_class=DeleteShadowResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/delete/rejected'.format(input),
+                payload_class=ErrorResponse,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def get_shadow(self, input):
+        # type: (GetShadowRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/shadow/get'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/get/accepted'.format(input),
+                payload_class=GetShadowResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/get/rejected'.format(input),
+                payload_class=ErrorResponse,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def subscribe_to_shadow_deltas(self, input, handler):
+        # type: (SubscribeToShadowDeltasRequest, ShadowDeltaEventsHandler) -> concurrent.futures.Future
+
+        if not handler.on_delta:
+            raise ValueError("handler.on_delta is required")
+
+        subscriptions = [
+            _SubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/update/delta'.format(input),
+                callback=handler.on_delta,
+                payload_class=ShadowDeltaEvent,
+            ),
+        ]
+
+        return self._subscribe_operation(subscriptions)
+
+    def subscribe_to_shadow_updates(self, input, handler):
+        # type: (SubscribeToShadowUpdatesRequest, ShadowUpdateEventsHandler) -> concurrent.futures.Future
+
+        if not handler.on_updated:
+            raise ValueError("handler.on_updated is required")
+
+        subscriptions = [
+            _SubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/update/documents'.format(input),
+                callback=handler.on_updated,
+                payload_class=ShadowUpdateEvent,
+            ),
+        ]
+
+        return self._subscribe_operation(subscriptions)
+
+    def update_shadow(self, input):
+        # type: (UpdateShadowRequest) -> concurrent.futures.Future
+        request_topic = '$aws/things/{0.thing_name}/shadow/update'.format(input)
+        subscriptions = [
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/update/accepted'.format(input),
+                payload_class=UpdateShadowResponse,
+                is_error=False,
+            ),
+            _RpcSubscriptionInfo(
+                topic='$aws/things/{0.thing_name}/shadow/update/rejected'.format(input),
+                payload_class=ErrorResponse,
+                is_error=True,
+            ),
+        ]
+
+        return self._rpc_operation(request_topic, input, subscriptions)
+
+    def _rpc_operation(self, pub_topic, input, subscriptions):
+        # type: (str, typing.Any, typing.List[_RpcSubscriptionInfo]) -> concurrent.futures.Future
+        """
+        Performs a 'Remote Procedure Call' style operation for an MQTT service.
+
+        Parameters:
+        pub_topic - Topic for request message.
+        input - Input object for request message.
+        subscriptions - List of _RpcSubscriptionInfos, one for each possible response.
+
+        Returns a Future that will contain the outcome of the operation.
+        A response from a non-error topic becomes a valid result in the Future.
+        A response from an error topic becomes an Exception in the Future.
+        Any other exception that occurs as part of the RPC becomes an exception in the Future.
+        """
+        if not input.client_token:
+            input.client_token = str(uuid.uuid4())
+        input_payload = input.to_payload()
+        input_json_payload = json.dumps(input_payload)
+
+        future = concurrent.futures.Future() # type: concurrent.futures.Future
+
+        suback_counter = ['suback'] * len(subscriptions)
+
+        # callback counts subacks, when last one is received the request is published.
+        def on_suback(packet_id):
+            try:
+                # count supacks by popping an entry out of this list
+                if suback_counter:
+                    suback_counter.pop()
+                    if not suback_counter:
+                        # all subscriptions succeeded, publish request
+                        self.mqtt_connection.publish(pub_topic, input_json_payload, 1, False, None)
+            except Exception as e:
+                future.set_exception(e)
+
+        for sub in subscriptions:
+            # callback transforms payload into appropriate class and delivers it to the future
+            def on_response(topic, json_payload):
+                try:
+                    payload = json.loads(json_payload)
+                    result = sub.payload_class.from_payload(payload)
+                    if sub.is_error:
+                        future.set_exception(result)
+                    else:
+                        future.set_result(result)
+                except Exception as e:
+                    future.set_exception(e)
+
+            self.mqtt_connection.subscribe(sub.topic, 1, on_response, on_suback)
+
+        return future
+
+    def _subscribe_operation(self, subscriptions):
+        # type: (typing.List[_SubscriptionInfo]) -> concurrent.futures.Future
+        """
+        Performs a 'Subscribe' style operation for an MQTT service.
+
+        Parameters:
+        subscriptions - List of _SubscriptionInfos, one for each possible response.
+
+        Returns a Future that will contain None when all subscriptions have been acknowledged by the server.
+        """
+
+        future = concurrent.futures.Future() # type: concurrent.futures.Future
+
+        # callback informs Future when all subacks received
+        suback_counter = ['suback'] * len(subscriptions)
+        def on_suback(packet_id):
+            # count supacks by popping an entry out of this list
+            if suback_counter:
+                suback_counter.pop()
+                if not suback_counter:
+                    # all subscriptions succeeded
+                    future.set_result(None)
+
+        for sub in subscriptions:
+            def callback_wrapper(topic, json_payload):
+                try:
+                    payload = json.loads(json_payload)
+                    event = sub.payload_class.from_payload(payload)
+                    sub.callback(event)
+                except:
+                    # can't deliver payload, invoke callback with None
+                    sub.callback(None)
+
+            self.mqtt_connection.subscribe(sub.topic, 1, callback_wrapper, on_suback)
+
+        return future
+
+T = typing.TypeVar('T')
+
+class _RpcSubscriptionInfo(object):
+    # type: typing.Generic[T]
+
+    def __init__(self, topic, payload_class, is_error):
+        # type: (str, typing.Type[T], bool) -> None
+        self.topic = topic # type: str
+        self.payload_class = payload_class # type: typing.Type[T]
+        self.is_error = is_error # type: bool
+
+class _SubscriptionInfo(object):
+    # type: typing.Generic[T]
+
+    def __init__(self, topic, callback, payload_class):
+        # type: (str, typing.Callable[[T], None], typing.Type[T]) -> None
+        self.topic = topic # type: str
+        self.callback = callback # type: typing.Callable[[T], None]
+        self.payload_class = payload_class # typing.Type[T]
+
+class DeleteShadowRequest(object):
+    def __init__(self, thing_name=None):
+        # type: (typing.Optional[str]) -> None
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+class DeleteShadowResponse(object):
+    def __init__(self, timestamp=None, version=None):
+        # type: (typing.Optional[datetime.datetime], typing.Optional[int]) -> None
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+        self.version = version # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> DeleteShadowResponse
+        new = cls()
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        val = payload.get('version')
+        if val:
+            new.version = val
+        return new
+
+class ErrorResponse(Exception):
+    def __init__(self, client_token=None, code=None, message=None, timestamp=None):
+        # type: (typing.Optional[str], typing.Optional[int], typing.Optional[str], typing.Optional[datetime.datetime]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.code = code # type: typing.Optional[int]
+        self.message = message # type: typing.Optional[str]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ErrorResponse
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('code')
+        if val:
+            new.code = val
+        val = payload.get('message')
+        if val:
+            new.message = val
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class GetShadowRequest(object):
+    def __init__(self, thing_name=None):
+        # type: (typing.Optional[str]) -> None
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+class GetShadowResponse(object):
+    def __init__(self, metadata=None, state=None, timestamp=None, version=None):
+        # type: (typing.Optional[ShadowMetadata], typing.Optional[ShadowStateWithDelta], typing.Optional[datetime.datetime], typing.Optional[int]) -> None
+        self.metadata = metadata # type: typing.Optional[ShadowMetadata]
+        self.state = state # type: typing.Optional[ShadowStateWithDelta]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+        self.version = version # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> GetShadowResponse
+        new = cls()
+        val = payload.get('metadata')
+        if val:
+            new.metadata = ShadowMetadata.from_payload(val)
+        val = payload.get('state')
+        if val:
+            new.state = ShadowStateWithDelta.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        val = payload.get('version')
+        if val:
+            new.version = val
+        return new
+
+class ShadowDeltaEvent(object):
+    def __init__(self, metadata=None, state=None, timestamp=None, version=None):
+        # type: (typing.Optional[typing.Dict[str, typing.Any]], typing.Optional[typing.Dict[str, typing.Any]], typing.Optional[datetime.datetime], typing.Optional[int]) -> None
+        self.metadata = metadata # type: typing.Optional[typing.Dict[str, typing.Any]]
+        self.state = state # type: typing.Optional[typing.Dict[str, typing.Any]]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+        self.version = version # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ShadowDeltaEvent
+        new = cls()
+        val = payload.get('metadata')
+        if val:
+            new.metadata = val
+        val = payload.get('state')
+        if val:
+            new.state = val
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        val = payload.get('version')
+        if val:
+            new.version = val
+        return new
+
+class ShadowDeltaEventsHandler:
+    def __init__(self):
+        self.on_delta = None # type: typing.Callable[[ShadowDeltaEvent], None]
+
+class ShadowMetadata(object):
+    def __init__(self, desired=None, reported=None):
+        # type: (typing.Optional[typing.Dict[str, typing.Any]], typing.Optional[typing.Dict[str, typing.Any]]) -> None
+        self.desired = desired # type: typing.Optional[typing.Dict[str, typing.Any]]
+        self.reported = reported # type: typing.Optional[typing.Dict[str, typing.Any]]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ShadowMetadata
+        new = cls()
+        val = payload.get('desired')
+        if val:
+            new.desired = val
+        val = payload.get('reported')
+        if val:
+            new.reported = val
+        return new
+
+class ShadowState(object):
+    def __init__(self, desired=None, reported=None):
+        # type: (typing.Optional[typing.Dict[str, typing.Any]], typing.Optional[typing.Dict[str, typing.Any]]) -> None
+        self.desired = desired # type: typing.Optional[typing.Dict[str, typing.Any]]
+        self.reported = reported # type: typing.Optional[typing.Dict[str, typing.Any]]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ShadowState
+        new = cls()
+        val = payload.get('desired')
+        if val:
+            new.desired = val
+        val = payload.get('reported')
+        if val:
+            new.reported = val
+        return new
+
+    def to_payload(self):
+        # type: () -> typing.Dict[str, typing.Any]
+        payload = {} # type: typing.Dict[str, typing.Any]
+        if self.desired:
+            payload['desired'] = self.desired
+        if self.reported:
+            payload['reported'] = self.reported
+        return payload
+
+class ShadowStateWithDelta(object):
+    def __init__(self, delta=None, desired=None, reported=None):
+        # type: (typing.Optional[typing.Dict[str, typing.Any]], typing.Optional[typing.Dict[str, typing.Any]], typing.Optional[typing.Dict[str, typing.Any]]) -> None
+        self.delta = delta # type: typing.Optional[typing.Dict[str, typing.Any]]
+        self.desired = desired # type: typing.Optional[typing.Dict[str, typing.Any]]
+        self.reported = reported # type: typing.Optional[typing.Dict[str, typing.Any]]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ShadowStateWithDelta
+        new = cls()
+        val = payload.get('delta')
+        if val:
+            new.delta = val
+        val = payload.get('desired')
+        if val:
+            new.desired = val
+        val = payload.get('reported')
+        if val:
+            new.reported = val
+        return new
+
+class ShadowUpdateEvent(object):
+    def __init__(self, current=None, previous=None, timestamp=None):
+        # type: (typing.Optional[ShadowUpdateSnapshot], typing.Optional[ShadowUpdateSnapshot], typing.Optional[datetime.datetime]) -> None
+        self.current = current # type: typing.Optional[ShadowUpdateSnapshot]
+        self.previous = previous # type: typing.Optional[ShadowUpdateSnapshot]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ShadowUpdateEvent
+        new = cls()
+        val = payload.get('current')
+        if val:
+            new.current = ShadowUpdateSnapshot.from_payload(val)
+        val = payload.get('previous')
+        if val:
+            new.previous = ShadowUpdateSnapshot.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        return new
+
+class ShadowUpdateEventsHandler:
+    def __init__(self):
+        self.on_updated = None # type: typing.Callable[[ShadowUpdateEvent], None]
+
+class ShadowUpdateSnapshot(object):
+    def __init__(self, metadata=None, state=None, version=None):
+        # type: (typing.Optional[ShadowMetadata], typing.Optional[ShadowState], typing.Optional[int]) -> None
+        self.metadata = metadata # type: typing.Optional[ShadowMetadata]
+        self.state = state # type: typing.Optional[ShadowState]
+        self.version = version # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> ShadowUpdateSnapshot
+        new = cls()
+        val = payload.get('metadata')
+        if val:
+            new.metadata = ShadowMetadata.from_payload(val)
+        val = payload.get('state')
+        if val:
+            new.state = ShadowState.from_payload(val)
+        val = payload.get('version')
+        if val:
+            new.version = val
+        return new
+
+class SubscribeToShadowDeltasRequest(object):
+    def __init__(self, thing_name=None):
+        # type: (typing.Optional[str]) -> None
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+class SubscribeToShadowUpdatesRequest(object):
+    def __init__(self, thing_name=None):
+        # type: (typing.Optional[str]) -> None
+        self.thing_name = thing_name # type: typing.Optional[str]
+
+class UpdateShadowRequest(object):
+    def __init__(self, client_token=None, state=None, thing_name=None, version=None):
+        # type: (typing.Optional[str], typing.Optional[ShadowState], typing.Optional[str], typing.Optional[int]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.state = state # type: typing.Optional[ShadowState]
+        self.thing_name = thing_name # type: typing.Optional[str]
+        self.version = version # type: typing.Optional[int]
+
+    def to_payload(self):
+        # type: () -> typing.Dict[str, typing.Any]
+        payload = {} # type: typing.Dict[str, typing.Any]
+        if self.client_token:
+            payload['clientToken'] = self.client_token
+        if self.state:
+            payload['state'] = self.state.to_payload()
+        if self.version:
+            payload['version'] = self.version
+        return payload
+
+class UpdateShadowResponse(object):
+    def __init__(self, client_token=None, metadata=None, state=None, timestamp=None, version=None):
+        # type: (typing.Optional[str], typing.Optional[ShadowMetadata], typing.Optional[ShadowState], typing.Optional[datetime.datetime], typing.Optional[int]) -> None
+        self.client_token = client_token # type: typing.Optional[str]
+        self.metadata = metadata # type: typing.Optional[ShadowMetadata]
+        self.state = state # type: typing.Optional[ShadowState]
+        self.timestamp = timestamp # type: typing.Optional[datetime.datetime]
+        self.version = version # type: typing.Optional[int]
+
+    @classmethod
+    def from_payload(cls, payload):
+        # type: (typing.Dict[str, typing.Any]) -> UpdateShadowResponse
+        new = cls()
+        val = payload.get('clientToken')
+        if val:
+            new.client_token = val
+        val = payload.get('metadata')
+        if val:
+            new.metadata = ShadowMetadata.from_payload(val)
+        val = payload.get('state')
+        if val:
+            new.state = ShadowState.from_payload(val)
+        val = payload.get('timestamp')
+        if val:
+            new.timestamp = datetime.datetime.fromtimestamp(val)
+        val = payload.get('version')
+        if val:
+            new.version = val
+        return new
+
diff --git a/setup.py b/setup.py
new file mode 100644
index 00000000..b76ad820
--- /dev/null
+++ b/setup.py
@@ -0,0 +1,14 @@
+#!/usr/bin/env python
+
+from distutils.core import setup
+
+setup(
+    name='awsiot',
+    version='2.0',
+    description='AWS IoT SDK based on the AWS Common Runtime',
+    author='AWS SDK Common Runtime Team',
+    url='https://github.com/awslabs/aws-iot-device-sdk-python-v2',
+    packages = ['awsiot'],
+    install_requires=['aws_crt.mqtt'],
+    python_requires='>=2.7',
+)