diff --git a/vsts/setup.py b/vsts/setup.py
index 0fa30ee9..952d38b5 100644
--- a/vsts/setup.py
+++ b/vsts/setup.py
@@ -6,7 +6,7 @@
 from setuptools import setup, find_packages
 
 NAME = "vsts"
-VERSION = "0.1.23"
+VERSION = "0.1.24"
 
 # To install the library, run the following
 #
diff --git a/vsts/vsts/build/v4_1/models/__init__.py b/vsts/vsts/build/v4_1/models/__init__.py
index 1ca89425..235110c5 100644
--- a/vsts/vsts/build/v4_1/models/__init__.py
+++ b/vsts/vsts/build/v4_1/models/__init__.py
@@ -1,4 +1,4 @@
-# --------------------------------------------------------------------------------------------
+# --------------------------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
@@ -21,7 +21,6 @@
 from .build_controller import BuildController
 from .build_definition import BuildDefinition
 from .build_definition3_2 import BuildDefinition3_2
-from .build_definition_counter import BuildDefinitionCounter
 from .build_definition_reference import BuildDefinitionReference
 from .build_definition_reference3_2 import BuildDefinitionReference3_2
 from .build_definition_revision import BuildDefinitionRevision
@@ -95,7 +94,6 @@
     'BuildController',
     'BuildDefinition',
     'BuildDefinition3_2',
-    'BuildDefinitionCounter',
     'BuildDefinitionReference',
     'BuildDefinitionReference3_2',
     'BuildDefinitionRevision',
diff --git a/vsts/vsts/build/v4_1/models/build_definition.py b/vsts/vsts/build/v4_1/models/build_definition.py
index 91cc7114..b7adaf5b 100644
--- a/vsts/vsts/build/v4_1/models/build_definition.py
+++ b/vsts/vsts/build/v4_1/models/build_definition.py
@@ -1,4 +1,4 @@
-# --------------------------------------------------------------------------------------------
+# --------------------------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
@@ -56,8 +56,6 @@ class BuildDefinition(BuildDefinitionReference):
     :type build_number_format: str
     :param comment: A save-time comment for the definition.
     :type comment: str
-    :param counters:
-    :type counters: dict
     :param demands:
     :type demands: list of :class:`object <build.v4_1.models.object>`
     :param description: The description.
@@ -115,7 +113,6 @@ class BuildDefinition(BuildDefinitionReference):
         'badge_enabled': {'key': 'badgeEnabled', 'type': 'bool'},
         'build_number_format': {'key': 'buildNumberFormat', 'type': 'str'},
         'comment': {'key': 'comment', 'type': 'str'},
-        'counters': {'key': 'counters', 'type': '{BuildDefinitionCounter}'},
         'demands': {'key': 'demands', 'type': '[object]'},
         'description': {'key': 'description', 'type': 'str'},
         'drop_location': {'key': 'dropLocation', 'type': 'str'},
@@ -134,12 +131,11 @@ class BuildDefinition(BuildDefinitionReference):
         'variables': {'key': 'variables', 'type': '{BuildDefinitionVariable}'}
     }
 
-    def __init__(self, created_date=None, id=None, name=None, path=None, project=None, queue_status=None, revision=None, type=None, uri=None, url=None, _links=None, authored_by=None, draft_of=None, drafts=None, latest_build=None, latest_completed_build=None, metrics=None, quality=None, queue=None, badge_enabled=None, build_number_format=None, comment=None, counters=None, demands=None, description=None, drop_location=None, job_authorization_scope=None, job_cancel_timeout_in_minutes=None, job_timeout_in_minutes=None, options=None, process=None, process_parameters=None, properties=None, repository=None, retention_rules=None, tags=None, triggers=None, variable_groups=None, variables=None):
+    def __init__(self, created_date=None, id=None, name=None, path=None, project=None, queue_status=None, revision=None, type=None, uri=None, url=None, _links=None, authored_by=None, draft_of=None, drafts=None, latest_build=None, latest_completed_build=None, metrics=None, quality=None, queue=None, badge_enabled=None, build_number_format=None, comment=None, demands=None, description=None, drop_location=None, job_authorization_scope=None, job_cancel_timeout_in_minutes=None, job_timeout_in_minutes=None, options=None, process=None, process_parameters=None, properties=None, repository=None, retention_rules=None, tags=None, triggers=None, variable_groups=None, variables=None):
         super(BuildDefinition, self).__init__(created_date=created_date, id=id, name=name, path=path, project=project, queue_status=queue_status, revision=revision, type=type, uri=uri, url=url, _links=_links, authored_by=authored_by, draft_of=draft_of, drafts=drafts, latest_build=latest_build, latest_completed_build=latest_completed_build, metrics=metrics, quality=quality, queue=queue)
         self.badge_enabled = badge_enabled
         self.build_number_format = build_number_format
         self.comment = comment
-        self.counters = counters
         self.demands = demands
         self.description = description
         self.drop_location = drop_location
diff --git a/vsts/vsts/gallery/v4_0/gallery_client.py b/vsts/vsts/gallery/v4_0/gallery_client.py
index 475c17af..89d3d43c 100644
--- a/vsts/vsts/gallery/v4_0/gallery_client.py
+++ b/vsts/vsts/gallery/v4_0/gallery_client.py
@@ -466,13 +466,17 @@ def query_extensions(self, extension_query, account_token=None):
                               content=content)
         return self._deserialize('ExtensionQueryResult', response)
 
-    def create_extension(self, upload_stream):
+    def create_extension(self, upload_stream, **kwargs):
         """CreateExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
         :rtype: :class:`<PublishedExtension> <gallery.v4_0.models.PublishedExtension>`
         """
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='a41192c8-9525-4b58-bc86-179fa549d80d',
                               version='4.0-preview.2',
@@ -536,7 +540,7 @@ def update_extension_by_id(self, extension_id):
                               route_values=route_values)
         return self._deserialize('PublishedExtension', response)
 
-    def create_extension_with_publisher(self, upload_stream, publisher_name):
+    def create_extension_with_publisher(self, upload_stream, publisher_name, **kwargs):
         """CreateExtensionWithPublisher.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -546,7 +550,11 @@ def create_extension_with_publisher(self, upload_stream, publisher_name):
         route_values = {}
         if publisher_name is not None:
             route_values['publisherName'] = self._serialize.url('publisher_name', publisher_name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='e11ea35a-16fe-4b80-ab11-c4cab88a0966',
                               version='4.0-preview.2',
@@ -605,7 +613,7 @@ def get_extension(self, publisher_name, extension_name, version=None, flags=None
                               query_parameters=query_parameters)
         return self._deserialize('PublishedExtension', response)
 
-    def update_extension(self, upload_stream, publisher_name, extension_name):
+    def update_extension(self, upload_stream, publisher_name, extension_name, **kwargs):
         """UpdateExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -618,7 +626,11 @@ def update_extension(self, upload_stream, publisher_name, extension_name):
             route_values['publisherName'] = self._serialize.url('publisher_name', publisher_name, 'str')
         if extension_name is not None:
             route_values['extensionName'] = self._serialize.url('extension_name', extension_name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='e11ea35a-16fe-4b80-ab11-c4cab88a0966',
                               version='4.0-preview.2',
diff --git a/vsts/vsts/gallery/v4_1/gallery_client.py b/vsts/vsts/gallery/v4_1/gallery_client.py
index 24536a77..eb9f3091 100644
--- a/vsts/vsts/gallery/v4_1/gallery_client.py
+++ b/vsts/vsts/gallery/v4_1/gallery_client.py
@@ -447,7 +447,7 @@ def perform_edit_extension_draft_operation(self, draft_patch, publisher_name, ex
                               content=content)
         return self._deserialize('ExtensionDraft', response)
 
-    def update_payload_in_draft_for_edit_extension(self, upload_stream, publisher_name, extension_name, draft_id, file_name=None):
+    def update_payload_in_draft_for_edit_extension(self, upload_stream, publisher_name, extension_name, draft_id, file_name=None, **kwargs):
         """UpdatePayloadInDraftForEditExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -464,7 +464,11 @@ def update_payload_in_draft_for_edit_extension(self, upload_stream, publisher_na
             route_values['extensionName'] = self._serialize.url('extension_name', extension_name, 'str')
         if draft_id is not None:
             route_values['draftId'] = self._serialize.url('draft_id', draft_id, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='02b33873-4e61-496e-83a2-59d1df46b7d8',
                               version='4.1-preview.1',
@@ -473,7 +477,7 @@ def update_payload_in_draft_for_edit_extension(self, upload_stream, publisher_na
                               media_type='application/octet-stream')
         return self._deserialize('ExtensionDraft', response)
 
-    def add_asset_for_edit_extension_draft(self, upload_stream, publisher_name, extension_name, draft_id, asset_type):
+    def add_asset_for_edit_extension_draft(self, upload_stream, publisher_name, extension_name, draft_id, asset_type, **kwargs):
         """AddAssetForEditExtensionDraft.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -492,7 +496,11 @@ def add_asset_for_edit_extension_draft(self, upload_stream, publisher_name, exte
             route_values['draftId'] = self._serialize.url('draft_id', draft_id, 'str')
         if asset_type is not None:
             route_values['assetType'] = self._serialize.url('asset_type', asset_type, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='f1db9c47-6619-4998-a7e5-d7f9f41a4617',
                               version='4.1-preview.1',
@@ -501,7 +509,7 @@ def add_asset_for_edit_extension_draft(self, upload_stream, publisher_name, exte
                               media_type='application/octet-stream')
         return self._deserialize('ExtensionDraftAsset', response)
 
-    def create_draft_for_new_extension(self, upload_stream, publisher_name, product, file_name=None):
+    def create_draft_for_new_extension(self, upload_stream, publisher_name, product, file_name=None, **kwargs):
         """CreateDraftForNewExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -513,7 +521,11 @@ def create_draft_for_new_extension(self, upload_stream, publisher_name, product,
         route_values = {}
         if publisher_name is not None:
             route_values['publisherName'] = self._serialize.url('publisher_name', publisher_name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='b3ab127d-ebb9-4d22-b611-4e09593c8d79',
                               version='4.1-preview.1',
@@ -543,7 +555,7 @@ def perform_new_extension_draft_operation(self, draft_patch, publisher_name, dra
                               content=content)
         return self._deserialize('ExtensionDraft', response)
 
-    def update_payload_in_draft_for_new_extension(self, upload_stream, publisher_name, draft_id, file_name=None):
+    def update_payload_in_draft_for_new_extension(self, upload_stream, publisher_name, draft_id, file_name=None, **kwargs):
         """UpdatePayloadInDraftForNewExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -557,7 +569,11 @@ def update_payload_in_draft_for_new_extension(self, upload_stream, publisher_nam
             route_values['publisherName'] = self._serialize.url('publisher_name', publisher_name, 'str')
         if draft_id is not None:
             route_values['draftId'] = self._serialize.url('draft_id', draft_id, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='b3ab127d-ebb9-4d22-b611-4e09593c8d79',
                               version='4.1-preview.1',
@@ -566,7 +582,7 @@ def update_payload_in_draft_for_new_extension(self, upload_stream, publisher_nam
                               media_type='application/octet-stream')
         return self._deserialize('ExtensionDraft', response)
 
-    def add_asset_for_new_extension_draft(self, upload_stream, publisher_name, draft_id, asset_type):
+    def add_asset_for_new_extension_draft(self, upload_stream, publisher_name, draft_id, asset_type, **kwargs):
         """AddAssetForNewExtensionDraft.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -582,7 +598,11 @@ def add_asset_for_new_extension_draft(self, upload_stream, publisher_name, draft
             route_values['draftId'] = self._serialize.url('draft_id', draft_id, 'str')
         if asset_type is not None:
             route_values['assetType'] = self._serialize.url('asset_type', asset_type, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='88c0b1c8-b4f1-498a-9b2a-8446ef9f32e7',
                               version='4.1-preview.1',
@@ -709,13 +729,17 @@ def query_extensions(self, extension_query, account_token=None):
                               content=content)
         return self._deserialize('ExtensionQueryResult', response)
 
-    def create_extension(self, upload_stream):
+    def create_extension(self, upload_stream, **kwargs):
         """CreateExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
         :rtype: :class:`<PublishedExtension> <gallery.v4_1.models.PublishedExtension>`
         """
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='a41192c8-9525-4b58-bc86-179fa549d80d',
                               version='4.1-preview.2',
@@ -779,7 +803,7 @@ def update_extension_by_id(self, extension_id):
                               route_values=route_values)
         return self._deserialize('PublishedExtension', response)
 
-    def create_extension_with_publisher(self, upload_stream, publisher_name):
+    def create_extension_with_publisher(self, upload_stream, publisher_name, **kwargs):
         """CreateExtensionWithPublisher.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -789,7 +813,11 @@ def create_extension_with_publisher(self, upload_stream, publisher_name):
         route_values = {}
         if publisher_name is not None:
             route_values['publisherName'] = self._serialize.url('publisher_name', publisher_name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='e11ea35a-16fe-4b80-ab11-c4cab88a0966',
                               version='4.1-preview.2',
@@ -848,7 +876,7 @@ def get_extension(self, publisher_name, extension_name, version=None, flags=None
                               query_parameters=query_parameters)
         return self._deserialize('PublishedExtension', response)
 
-    def update_extension(self, upload_stream, publisher_name, extension_name):
+    def update_extension(self, upload_stream, publisher_name, extension_name, **kwargs):
         """UpdateExtension.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -861,7 +889,11 @@ def update_extension(self, upload_stream, publisher_name, extension_name):
             route_values['publisherName'] = self._serialize.url('publisher_name', publisher_name, 'str')
         if extension_name is not None:
             route_values['extensionName'] = self._serialize.url('extension_name', extension_name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='e11ea35a-16fe-4b80-ab11-c4cab88a0966',
                               version='4.1-preview.2',
@@ -1032,7 +1064,7 @@ def get_publisher_asset(self, publisher_name, asset_type=None, **kwargs):
             callback = None
         return self._client.stream_download(response, callback=callback)
 
-    def update_publisher_asset(self, upload_stream, publisher_name, asset_type=None, file_name=None):
+    def update_publisher_asset(self, upload_stream, publisher_name, asset_type=None, file_name=None, **kwargs):
         """UpdatePublisherAsset.
         [Preview API] Update publisher asset like logo. It accepts asset file as an octet stream and file name is passed in header values.
         :param object upload_stream: Stream to upload
@@ -1047,7 +1079,11 @@ def update_publisher_asset(self, upload_stream, publisher_name, asset_type=None,
         query_parameters = {}
         if asset_type is not None:
             query_parameters['assetType'] = self._serialize.query('asset_type', asset_type, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='21143299-34f9-4c62-8ca8-53da691192f9',
                               version='4.1-preview.1',
diff --git a/vsts/vsts/git/v4_0/git_client_base.py b/vsts/vsts/git/v4_0/git_client_base.py
index f174a315..79fa509a 100644
--- a/vsts/vsts/git/v4_0/git_client_base.py
+++ b/vsts/vsts/git/v4_0/git_client_base.py
@@ -1048,7 +1048,7 @@ def get_items_batch(self, request_data, repository_id, project=None):
                               content=content)
         return self._deserialize('[[GitItem]]', self._unwrap_collection(response))
 
-    def create_attachment(self, upload_stream, file_name, repository_id, pull_request_id, project=None):
+    def create_attachment(self, upload_stream, file_name, repository_id, pull_request_id, project=None, **kwargs):
         """CreateAttachment.
         [Preview API] Create a new attachment
         :param object upload_stream: Stream to upload
@@ -1067,7 +1067,11 @@ def create_attachment(self, upload_stream, file_name, repository_id, pull_reques
             route_values['repositoryId'] = self._serialize.url('repository_id', repository_id, 'str')
         if pull_request_id is not None:
             route_values['pullRequestId'] = self._serialize.url('pull_request_id', pull_request_id, 'int')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='965d9361-878b-413b-a494-45d5b5fd8ab7',
                               version='4.0-preview.1',
diff --git a/vsts/vsts/git/v4_1/git_client_base.py b/vsts/vsts/git/v4_1/git_client_base.py
index e91e63b4..a1aa9b5c 100644
--- a/vsts/vsts/git/v4_1/git_client_base.py
+++ b/vsts/vsts/git/v4_1/git_client_base.py
@@ -1071,7 +1071,7 @@ def get_merge_bases(self, repository_name_or_id, commit_id, other_commit_id, pro
                               query_parameters=query_parameters)
         return self._deserialize('[GitCommitRef]', self._unwrap_collection(response))
 
-    def create_attachment(self, upload_stream, file_name, repository_id, pull_request_id, project=None):
+    def create_attachment(self, upload_stream, file_name, repository_id, pull_request_id, project=None, **kwargs):
         """CreateAttachment.
         [Preview API] Attach a new file to a pull request.
         :param object upload_stream: Stream to upload
@@ -1090,7 +1090,11 @@ def create_attachment(self, upload_stream, file_name, repository_id, pull_reques
             route_values['repositoryId'] = self._serialize.url('repository_id', repository_id, 'str')
         if pull_request_id is not None:
             route_values['pullRequestId'] = self._serialize.url('pull_request_id', pull_request_id, 'int')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='965d9361-878b-413b-a494-45d5b5fd8ab7',
                               version='4.1-preview.1',
diff --git a/vsts/vsts/task/v4_0/task_client.py b/vsts/vsts/task/v4_0/task_client.py
index 1d18c989..068b4010 100644
--- a/vsts/vsts/task/v4_0/task_client.py
+++ b/vsts/vsts/task/v4_0/task_client.py
@@ -49,7 +49,7 @@ def get_plan_attachments(self, scope_identifier, hub_name, plan_id, type):
                               route_values=route_values)
         return self._deserialize('[TaskAttachment]', self._unwrap_collection(response))
 
-    def create_attachment(self, upload_stream, scope_identifier, hub_name, plan_id, timeline_id, record_id, type, name):
+    def create_attachment(self, upload_stream, scope_identifier, hub_name, plan_id, timeline_id, record_id, type, name, **kwargs):
         """CreateAttachment.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -77,7 +77,11 @@ def create_attachment(self, upload_stream, scope_identifier, hub_name, plan_id,
             route_values['type'] = self._serialize.url('type', type, 'str')
         if name is not None:
             route_values['name'] = self._serialize.url('name', name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='7898f959-9cdf-4096-b29e-7f293031629e',
                               version='4.0-preview.1',
@@ -214,7 +218,7 @@ def append_timeline_record_feed(self, lines, scope_identifier, hub_name, plan_id
                    route_values=route_values,
                    content=content)
 
-    def append_log_content(self, upload_stream, scope_identifier, hub_name, plan_id, log_id):
+    def append_log_content(self, upload_stream, scope_identifier, hub_name, plan_id, log_id, **kwargs):
         """AppendLogContent.
         :param object upload_stream: Stream to upload
         :param str scope_identifier: The project GUID to scope the request
@@ -232,7 +236,11 @@ def append_log_content(self, upload_stream, scope_identifier, hub_name, plan_id,
             route_values['planId'] = self._serialize.url('plan_id', plan_id, 'str')
         if log_id is not None:
             route_values['logId'] = self._serialize.url('log_id', log_id, 'int')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='46f5667d-263a-4684-91b1-dff7fdcf64e2',
                               version='4.0',
diff --git a/vsts/vsts/task/v4_1/task_client.py b/vsts/vsts/task/v4_1/task_client.py
index fd618acb..fce502f9 100644
--- a/vsts/vsts/task/v4_1/task_client.py
+++ b/vsts/vsts/task/v4_1/task_client.py
@@ -49,7 +49,7 @@ def get_plan_attachments(self, scope_identifier, hub_name, plan_id, type):
                               route_values=route_values)
         return self._deserialize('[TaskAttachment]', self._unwrap_collection(response))
 
-    def create_attachment(self, upload_stream, scope_identifier, hub_name, plan_id, timeline_id, record_id, type, name):
+    def create_attachment(self, upload_stream, scope_identifier, hub_name, plan_id, timeline_id, record_id, type, name, **kwargs):
         """CreateAttachment.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -77,7 +77,11 @@ def create_attachment(self, upload_stream, scope_identifier, hub_name, plan_id,
             route_values['type'] = self._serialize.url('type', type, 'str')
         if name is not None:
             route_values['name'] = self._serialize.url('name', name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='7898f959-9cdf-4096-b29e-7f293031629e',
                               version='4.1-preview.1',
@@ -187,7 +191,7 @@ def get_attachments(self, scope_identifier, hub_name, plan_id, timeline_id, reco
                               route_values=route_values)
         return self._deserialize('[TaskAttachment]', self._unwrap_collection(response))
 
-    def append_log_content(self, upload_stream, scope_identifier, hub_name, plan_id, log_id):
+    def append_log_content(self, upload_stream, scope_identifier, hub_name, plan_id, log_id, **kwargs):
         """AppendLogContent.
         :param object upload_stream: Stream to upload
         :param str scope_identifier: The project GUID to scope the request
@@ -205,7 +209,11 @@ def append_log_content(self, upload_stream, scope_identifier, hub_name, plan_id,
             route_values['planId'] = self._serialize.url('plan_id', plan_id, 'str')
         if log_id is not None:
             route_values['logId'] = self._serialize.url('log_id', log_id, 'int')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='46f5667d-263a-4684-91b1-dff7fdcf64e2',
                               version='4.1',
diff --git a/vsts/vsts/task_agent/v4_0/task_agent_client.py b/vsts/vsts/task_agent/v4_0/task_agent_client.py
index b88abe6c..1626fb5d 100644
--- a/vsts/vsts/task_agent/v4_0/task_agent_client.py
+++ b/vsts/vsts/task_agent/v4_0/task_agent_client.py
@@ -1733,7 +1733,7 @@ def update_secure_files(self, secure_files, project):
                               content=content)
         return self._deserialize('[SecureFile]', self._unwrap_collection(response))
 
-    def upload_secure_file(self, upload_stream, project, name):
+    def upload_secure_file(self, upload_stream, project, name, **kwargs):
         """UploadSecureFile.
         [Preview API] Upload a secure file, include the file stream in the request body
         :param object upload_stream: Stream to upload
@@ -1747,7 +1747,11 @@ def upload_secure_file(self, upload_stream, project, name):
         query_parameters = {}
         if name is not None:
             query_parameters['name'] = self._serialize.query('name', name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='adcfd8bc-b184-43ba-bd84-7c8c6a2ff421',
                               version='4.0-preview.1',
diff --git a/vsts/vsts/version.py b/vsts/vsts/version.py
index 2a55b701..801a7935 100644
--- a/vsts/vsts/version.py
+++ b/vsts/vsts/version.py
@@ -3,4 +3,4 @@
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
 
-VERSION = "0.1.23"
+VERSION = "0.1.24"
diff --git a/vsts/vsts/wiki/v4_0/wiki_client.py b/vsts/vsts/wiki/v4_0/wiki_client.py
index ebd75092..6c3e2cac 100644
--- a/vsts/vsts/wiki/v4_0/wiki_client.py
+++ b/vsts/vsts/wiki/v4_0/wiki_client.py
@@ -25,7 +25,7 @@ def __init__(self, base_url=None, creds=None):
 
     resource_area_identifier = 'bf7d82a0-8aa5-4613-94ef-6172a5ea01f3'
 
-    def create_attachment(self, upload_stream, project, wiki_id, name):
+    def create_attachment(self, upload_stream, project, wiki_id, name, **kwargs):
         """CreateAttachment.
         [Preview API] Use this API to create an attachment in the wiki.
         :param object upload_stream: Stream to upload
@@ -42,7 +42,11 @@ def create_attachment(self, upload_stream, project, wiki_id, name):
         query_parameters = {}
         if name is not None:
             query_parameters['name'] = self._serialize.query('name', name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='c4382d8d-fefc-40e0-92c5-49852e9e17c0',
                               version='4.0-preview.1',
diff --git a/vsts/vsts/wiki/v4_1/wiki_client.py b/vsts/vsts/wiki/v4_1/wiki_client.py
index 26764617..6ff6aec6 100644
--- a/vsts/vsts/wiki/v4_1/wiki_client.py
+++ b/vsts/vsts/wiki/v4_1/wiki_client.py
@@ -25,7 +25,7 @@ def __init__(self, base_url=None, creds=None):
 
     resource_area_identifier = 'bf7d82a0-8aa5-4613-94ef-6172a5ea01f3'
 
-    def create_attachment(self, upload_stream, project, wiki_identifier, name):
+    def create_attachment(self, upload_stream, project, wiki_identifier, name, **kwargs):
         """CreateAttachment.
         Creates an attachment in the wiki.
         :param object upload_stream: Stream to upload
@@ -41,7 +41,11 @@ def create_attachment(self, upload_stream, project, wiki_identifier, name):
             route_values['wikiIdentifier'] = self._serialize.url('wiki_identifier', wiki_identifier, 'str')
         if name is not None:
             route_values['name'] = self._serialize.url('name', name, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='PUT',
                               location_id='c4382d8d-fefc-40e0-92c5-49852e9e17c0',
                               version='4.1',
diff --git a/vsts/vsts/work_item_tracking/v4_0/work_item_tracking_client.py b/vsts/vsts/work_item_tracking/v4_0/work_item_tracking_client.py
index 69e222cf..c247d731 100644
--- a/vsts/vsts/work_item_tracking/v4_0/work_item_tracking_client.py
+++ b/vsts/vsts/work_item_tracking/v4_0/work_item_tracking_client.py
@@ -48,7 +48,7 @@ def get_work_item_ids_for_artifact_uris(self, artifact_uri_query):
                               content=content)
         return self._deserialize('ArtifactUriQueryResult', response)
 
-    def create_attachment(self, upload_stream, file_name=None, upload_type=None, area_path=None):
+    def create_attachment(self, upload_stream, file_name=None, upload_type=None, area_path=None, **kwargs):
         """CreateAttachment.
         Creates an attachment.
         :param object upload_stream: Stream to upload
@@ -64,7 +64,11 @@ def create_attachment(self, upload_stream, file_name=None, upload_type=None, are
             query_parameters['uploadType'] = self._serialize.query('upload_type', upload_type, 'str')
         if area_path is not None:
             query_parameters['areaPath'] = self._serialize.query('area_path', area_path, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='e07b5fa4-1499-494d-a496-64b860fd64ff',
                               version='4.0',
diff --git a/vsts/vsts/work_item_tracking/v4_1/work_item_tracking_client.py b/vsts/vsts/work_item_tracking/v4_1/work_item_tracking_client.py
index eb586023..ca90f6b5 100644
--- a/vsts/vsts/work_item_tracking/v4_1/work_item_tracking_client.py
+++ b/vsts/vsts/work_item_tracking/v4_1/work_item_tracking_client.py
@@ -53,7 +53,7 @@ def query_work_items_for_artifact_uris(self, artifact_uri_query, project=None):
                               content=content)
         return self._deserialize('ArtifactUriQueryResult', response)
 
-    def create_attachment(self, upload_stream, project=None, file_name=None, upload_type=None, area_path=None):
+    def create_attachment(self, upload_stream, project=None, file_name=None, upload_type=None, area_path=None, **kwargs):
         """CreateAttachment.
         Uploads an attachment.
         :param object upload_stream: Stream to upload
@@ -73,7 +73,11 @@ def create_attachment(self, upload_stream, project=None, file_name=None, upload_
             query_parameters['uploadType'] = self._serialize.query('upload_type', upload_type, 'str')
         if area_path is not None:
             query_parameters['areaPath'] = self._serialize.query('area_path', area_path, 'str')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='e07b5fa4-1499-494d-a496-64b860fd64ff',
                               version='4.1',
diff --git a/vsts/vsts/work_item_tracking_process_template/v4_0/work_item_tracking_process_template_client.py b/vsts/vsts/work_item_tracking_process_template/v4_0/work_item_tracking_process_template_client.py
index 9a290a73..96d2060a 100644
--- a/vsts/vsts/work_item_tracking_process_template/v4_0/work_item_tracking_process_template_client.py
+++ b/vsts/vsts/work_item_tracking_process_template/v4_0/work_item_tracking_process_template_client.py
@@ -60,7 +60,7 @@ def get_behaviors(self, process_id):
                               route_values=route_values)
         return self._deserialize('[AdminBehavior]', self._unwrap_collection(response))
 
-    def check_template_existence(self, upload_stream):
+    def check_template_existence(self, upload_stream, **kwargs):
         """CheckTemplateExistence.
         [Preview API] Check if process template exists
         :param object upload_stream: Stream to upload
@@ -68,7 +68,11 @@ def check_template_existence(self, upload_stream):
         """
         route_values = {}
         route_values['action'] = 'CheckTemplateExistence'
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='29e1f38d-9e9c-4358-86a5-cdf9896a5759',
                               version='4.0-preview.1',
@@ -100,7 +104,7 @@ def export_process_template(self, id, **kwargs):
             callback = None
         return self._client.stream_download(response, callback=callback)
 
-    def import_process_template(self, upload_stream, ignore_warnings=None):
+    def import_process_template(self, upload_stream, ignore_warnings=None, **kwargs):
         """ImportProcessTemplate.
         [Preview API]
         :param object upload_stream: Stream to upload
@@ -112,7 +116,11 @@ def import_process_template(self, upload_stream, ignore_warnings=None):
         query_parameters = {}
         if ignore_warnings is not None:
             query_parameters['ignoreWarnings'] = self._serialize.query('ignore_warnings', ignore_warnings, 'bool')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='29e1f38d-9e9c-4358-86a5-cdf9896a5759',
                               version='4.0-preview.1',
diff --git a/vsts/vsts/work_item_tracking_process_template/v4_1/work_item_tracking_process_template_client.py b/vsts/vsts/work_item_tracking_process_template/v4_1/work_item_tracking_process_template_client.py
index 19a8b8fa..583c9253 100644
--- a/vsts/vsts/work_item_tracking_process_template/v4_1/work_item_tracking_process_template_client.py
+++ b/vsts/vsts/work_item_tracking_process_template/v4_1/work_item_tracking_process_template_client.py
@@ -60,7 +60,7 @@ def get_behaviors(self, process_id):
                               route_values=route_values)
         return self._deserialize('[AdminBehavior]', self._unwrap_collection(response))
 
-    def check_template_existence(self, upload_stream):
+    def check_template_existence(self, upload_stream, **kwargs):
         """CheckTemplateExistence.
         [Preview API] Check if process template exists.
         :param object upload_stream: Stream to upload
@@ -68,7 +68,11 @@ def check_template_existence(self, upload_stream):
         """
         route_values = {}
         route_values['action'] = 'CheckTemplateExistence'
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='29e1f38d-9e9c-4358-86a5-cdf9896a5759',
                               version='4.1-preview.1',
@@ -98,7 +102,7 @@ def export_process_template(self, id, **kwargs):
             callback = None
         return self._client.stream_download(response, callback=callback)
 
-    def import_process_template(self, upload_stream, ignore_warnings=None):
+    def import_process_template(self, upload_stream, ignore_warnings=None, **kwargs):
         """ImportProcessTemplate.
         [Preview API] Imports a process from zip file.
         :param object upload_stream: Stream to upload
@@ -110,7 +114,11 @@ def import_process_template(self, upload_stream, ignore_warnings=None):
         query_parameters = {}
         if ignore_warnings is not None:
             query_parameters['ignoreWarnings'] = self._serialize.query('ignore_warnings', ignore_warnings, 'bool')
-        content = self._serialize.body(upload_stream, 'object')
+        if "callback" in kwargs:
+            callback = kwargs["callback"]
+        else:
+            callback = None
+        content = self._client.stream_upload(upload_stream, callback=callback)
         response = self._send(http_method='POST',
                               location_id='29e1f38d-9e9c-4358-86a5-cdf9896a5759',
                               version='4.1-preview.1',