(self, state=False)
| 286 | |
| 287 | @shared_task(bind=True) |
| 288 | def second_order_replace1(self, state=False): |
| 289 | redis_connection = get_redis_connection() |
| 290 | if not state: |
| 291 | redis_connection.rpush('redis-echo', 'In A') |
| 292 | new_task = chain(second_order_replace2.s(), |
| 293 | second_order_replace1.si(state=True)) |
| 294 | raise self.replace(new_task) |
| 295 | else: |
| 296 | redis_connection.rpush('redis-echo', 'Out A') |
| 297 | |
| 298 | |
| 299 | @shared_task(bind=True) |