New Research: Supply Chain Attack on Axios Pulls Malicious Dependency from npm.Details →
Socket
Book a DemoSign in
Socket

task-queue

Package Overview
Dependencies
Maintainers
1
Versions
64
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

task-queue - pypi Package Compare versions

Comparing version
2.12.1
to
2.13.0
+1
-1
PKG-INFO
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