()
| 59 | signal_was_called(True) |
| 60 | |
| 61 | def thread_worker(): |
| 62 | set_default_app(celery_setup.app) |
| 63 | identity.si("Published from thread").apply_async( |
| 64 | queue=celery_setup.worker.worker_queue |
| 65 | ) |
| 66 | |
| 67 | executor = ThreadPoolExecutor(threads_count) |
| 68 |
nothing calls this directly
no test coverage detected