0.8.1: explicitly pass taskId and runId from the azure json #17

Merged
merged 2 commits into from Oct 18, 2016
Next

explicitly pass taskId and runId from the azure json

commit d782b04c7d776bcf73c9290b8f7f41e8a7d9124c @escapewindow escapewindow committed Oct 17, 2016
View
@@ -3,6 +3,8 @@ All notable changes to this project will be documented in this file.
This project adheres to [Semantic Versioning](http://semver.org/).
## Unreleased
+### Fixed
+- explicitly pass `taskId` and `runId` to `claim_task`. There's a new `hintId` property that appears in `message_info['task_info']` that broke things.
## [0.8.0] - 2016-10-13
### Added
@@ -117,7 +117,7 @@ def get_azure_urls(context):
"""
xml = await request_function(context, poll_url)
for message_info in parse_azure_xml(xml):
- task = await claim_task(context, **message_info['task_info'])
+ task = await claim_task(context, message_info['task_info']['taskId'], message_info['task_info']['runId'])
if task is not None:
log.info("Found task! Deleting from azure...")
delete_url = delete_url.replace("{{", "{").replace("}}", "}").format(**message_info)
@@ -49,7 +49,7 @@ def get_version_string(version):
# 1}}}
# Semantic versioning 2.0.0 http://semver.org/
-__version__ = (0, 8, 0)
+__version__ = (0, 8, 1, "alpha1")
__version_string__ = get_version_string(__version__)
View
@@ -2,7 +2,8 @@
"version": [
0,
8,
- 0
+ 1,
+ "alpha1"
],
- "version_string": "0.8.0"
+ "version_string": "0.8.1-alpha1"
}