diff --git a/validator/app/src/compute_horde_validator/settings.py b/validator/app/src/compute_horde_validator/settings.py index 8af73b8e7..368eb4081 100644 --- a/validator/app/src/compute_horde_validator/settings.py +++ b/validator/app/src/compute_horde_validator/settings.py @@ -134,12 +134,12 @@ def wrapped(*args, **kwargs): CONSTANCE_BACKEND = "constance.backends.database.DatabaseBackend" CONSTANCE_DATABASE_CACHE_BACKEND = "default" CONSTANCE_CONFIG = { - "SYNC_ORGANIC_JOBS": (False, "SYNC_ORGANIC_JOBS", bool), "SERVING": ( not env.bool("MIGRATING", default=False), "Whether this validator is serving jobs and setting weights", bool, ), + "DYNAMIC_SYNC_ORGANIC_JOBS": (False, "Run the sync implementation of organic jobs", bool), "DYNAMIC_DUMMY": (0, "Dummy config for the purpose of testing", int), "DYNAMIC_MANIFEST_SCORE_MULTIPLIER": ( 1.05, diff --git a/validator/app/src/compute_horde_validator/validator/tasks.py b/validator/app/src/compute_horde_validator/validator/tasks.py index 47cd3e3c4..997376ab5 100644 --- a/validator/app/src/compute_horde_validator/validator/tasks.py +++ b/validator/app/src/compute_horde_validator/validator/tasks.py @@ -278,7 +278,7 @@ def _execute_organic_job_on_worker(job_request: JsonValue, job_route: JsonValue) request: OrganicJobRequest = TypeAdapter(OrganicJobRequest).validate_python(job_request) route: JobRoute = TypeAdapter(JobRoute).validate_python(job_route) - if config.SYNC_ORGANIC_JOBS: + if config.DYNAMIC_SYNC_ORGANIC_JOBS: execute_organic_job_request_sync(request, route) else: async_to_sync(execute_organic_job_request)(request, route)