Skip to content

CIRCLE / cloud

Go to a project
Commit d933efca by Őry Máté
Options

common: fix queue name

parent 73e82fe8
Showing with 4 additions and 3 deletions
circle/common/models.py
...@@ -292,9 +292,10 @@ def method_cache(memcached_seconds=60, instance_seconds=5): # noqa ...@@ -292,9 +292,10 @@ def method_cache(memcached_seconds=60, instance_seconds=5): # noqa
elif not cache.get("%s.cached" % key): elif not cache.get("%s.cached" % key):
logger.debug("caches expiring, compute async") logger.debug("caches expiring, compute async")
cache.set("%s.cached" % key, 1, memcached_seconds * 0.5) cache.set("%s.cached" % key, 1, memcached_seconds * 0.5)
compute_cached.delay( compute_cached.apply_async(
method_name, (instance.__class__, instance.id), queue='localhost.man', kwargs=kwargs, args=[
memcached_seconds, key, time(), *args, **kwargs) method_name, (instance.__class__, instance.id),
memcached_seconds, key, time()] + list(args))
return result return result
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment