■ ■ ■ ■ ■ ■
changedetectionio/__init__.py
| skipped 1040 lines |
| 1041 | 1041 | | def ticker_thread_check_time_launch_checks(): |
| 1042 | 1042 | | from changedetectionio import update_worker |
| 1043 | 1043 | | |
| 1044 | | - | # Spin up Workers. |
| 1045 | | - | for _ in range(datastore.data['settings']['requests']['workers']): |
| | 1044 | + | # Spin up Workers that do the fetching |
| | 1045 | + | # Can be overriden by ENV or use the default settings |
| | 1046 | + | n_workers = os.getenv("FETCH_WORKERS", datastore.data['settings']['requests']['workers']) |
| | 1047 | + | for _ in range(n_workers): |
| 1046 | 1048 | | new_worker = update_worker.update_worker(update_q, notification_q, app, datastore) |
| 1047 | 1049 | | running_update_threads.append(new_worker) |
| 1048 | 1050 | | new_worker.start() |
| skipped 35 lines |
