task-queue
Advanced tools
+1
-1
| Metadata-Version: 2.1 | ||
| Name: task-queue | ||
| Version: 2.12.1 | ||
| Version: 2.13.0 | ||
| Summary: Multithreaded cloud queue client. | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/seung-lab/python-task-queue/ |
@@ -1,1 +0,1 @@ | ||
| {"git_version": "1d13d60", "is_release": true} | ||
| {"git_version": "6eea2cf", "is_release": true} |
| Metadata-Version: 2.1 | ||
| Name: task-queue | ||
| Version: 2.12.1 | ||
| Version: 2.13.0 | ||
| Summary: Multithreaded cloud queue client. | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/seung-lab/python-task-queue/ |
| import os | ||
| import math | ||
| import importlib | ||
@@ -75,3 +76,4 @@ import click | ||
| @click.argument("dest") | ||
| def cp(src, dest): | ||
| @click.option('--load', default=None, help="Load a module to get task definitions.", show_default=True) | ||
| def cp(src, dest, load): | ||
| """ | ||
@@ -86,2 +88,5 @@ Copy the contents of a queue to another | ||
| """ | ||
| if load: | ||
| importlib.import_module(load) | ||
| src = normalize_path(src) | ||
@@ -88,0 +93,0 @@ dest = normalize_path(dest) |
@@ -8,2 +8,2 @@ from .registered_task import RegisteredTask, MockTask, PrintTask | ||
| __version__ = '2.12.1' | ||
| __version__ = '2.13.0' |
@@ -146,7 +146,12 @@ import json | ||
| def renew_lease(self, seconds): | ||
| raise NotImplementedError() | ||
| @retry | ||
| def renew_lease(self, task, seconds): | ||
| self.sqs.change_message_visibility( | ||
| QueueUrl=self.qurl, | ||
| ReceiptHandle=task.id, | ||
| VisibilityTimeout=seconds, | ||
| ) | ||
| def cancel_lease(self, rhandle): | ||
| raise NotImplementedError() | ||
| def cancel_lease(self, task): | ||
| self.renew_lease(task, 0) | ||
@@ -153,0 +158,0 @@ def release_all(self): |
Sorry, the diff of this file is not supported yet
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
162887
0.29%2290
0.39%