A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: ensure(self._set, (key, value), **retry_policy) def _set(self, key, value): with self.client.pipeline() as pipe: if self.expires: pipe.setex(key, self.expires, value) state) encoded = self.encode([1, tid, state, result]) with client.pipeline() as pipe: pipeline = ( pipe.zadd(jkey, {encoded: group_index}).zcount(jkey, "- inf"

A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: ensure(self._set, (key, value), **retry_policy) def _set(self, key, value): with self.client.pipeline() as pipe: if self.expires: pipe.setex(key, self.expires, value) state) encoded = self.encode([1, tid, state, result]) with client.pipeline() as pipe: pipeline = ( pipe.zadd(jkey, {encoded: group_index}).zcount(jkey, "- inf"

A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: ensure(self._set, (key, value), **retry_policy) def _set(self, key, value): with self.client.pipeline() as pipe: if self.expires: pipe.setex(key, self.expires, value) state) encoded = self.encode([1, tid, state, result]) with client.pipeline() as pipe: pipeline = ( pipe.zadd(jkey, {encoded: group_index}).zcount(jkey, "- inf"

A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: ensure(self._set, (key, value), **retry_policy) def _set(self, key, value): with self.client.pipeline() as pipe: if self.expires: pipe.setex(key, self.expires, value) state) encoded = self.encode([1, tid, state, result]) with client.pipeline() as pipe: pipeline = ( pipe.zadd(jkey, {encoded: group_index}).zcount(jkey, "- inf"

A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: ensure(self._set, (key, value), **retry_policy) def _set(self, key, value): with self.client.pipeline() as pipe: if self.expires: pipe.setex(key, self.expires, value) get_key_for_group(gid, '.t') result = self.encode_result(result, state) with client.pipeline() as pipe: _, readycount, totaldiff, _, _ = pipe \

A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: ensure(self._set, (key, value), **retry_policy) def _set(self, key, value): with self.client.pipeline() as pipe: if self.expires: pipe.setex(key, self.expires, value) get_key_for_group(gid, '.t') result = self.encode_result(result, state) with client.pipeline() as pipe: _, readycount, totaldiff, _, _ = pipe \

A regression caused Ctrl+C to be ineffective for shutdown. • Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. • Redis result

: A regression caused Ctrl+C to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend:

regression caused Control-c to be ineffective for shutdown. • Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. • Redis result

A regression caused Control-c to be ineffective for shutdown. Redis result backend: Now using a pipeline to store state changes for improved performance. Contributed by Pepijn de Vos. Redis result backend: