Skip to content

Commit

Permalink
Merge pull request #30 from cuda-networks/execute_inline_bugfix
Browse files Browse the repository at this point in the history
make sure kwarg is popped in any case
  • Loading branch information
alexeyts authored Oct 30, 2018
2 parents f3ebd51 + 70dcbb0 commit d3928f7
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions eb_sqs/decorators.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ def wrapper(*args, **kwargs):
max_retries = _get_kwarg_val(kwargs, 'max_retries', max_retries_count if max_retries_count else settings.DEFAULT_MAX_RETRIES)
pickle = _get_kwarg_val(kwargs, 'use_pickle', use_pickle if use_pickle else settings.USE_PICKLE)

execute_inline = True if settings.EXECUTE_INLINE else _get_kwarg_val(kwargs, 'execute_inline', False)
execute_inline = _get_kwarg_val(kwargs, 'execute_inline', False) or settings.EXECUTE_INLINE
delay = _get_kwarg_val(kwargs, 'delay', settings.DEFAULT_DELAY)
group_id = _get_kwarg_val(kwargs, 'group_id', None)

Expand All @@ -32,7 +32,7 @@ def func_retry_decorator(worker_task):
# type: (WorkerTask) -> (tuple, dict)
def wrapper(*args, **kwargs):
# type: (tuple, dict) -> Any
execute_inline = True if settings.EXECUTE_INLINE else _get_kwarg_val(kwargs, 'execute_inline', False)
execute_inline = _get_kwarg_val(kwargs, 'execute_inline', False) or settings.EXECUTE_INLINE
delay = _get_kwarg_val(kwargs, 'delay', settings.DEFAULT_DELAY)
count_retries = _get_kwarg_val(kwargs, 'count_retries', settings.DEFAULT_COUNT_RETRIES)

Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

setup(
name='django-eb-sqs',
version='1.11',
version='1.12',
package_dir={'eb_sqs': 'eb_sqs'},
include_package_data=True,
packages=find_packages(),
Expand Down

0 comments on commit d3928f7

Please sign in to comment.