Skip to content

Commit 4ef1366

Browse files
carlinmackslint
authored andcommitted
config: add IS_LOCAL_DEV var and fix default env
1 parent 70def9e commit 4ef1366

File tree

1 file changed

+65
-59
lines changed

1 file changed

+65
-59
lines changed

invenio.cfg

+65-59
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,12 @@ RDM_COMMUNITIES_ROUTES["community-home"] = (
117117
communities_home,
118118
)
119119

120-
ZENODO_ENV = os.environ.get("ZENODO_ENV", "production").lower()
120+
ZENODO_ENV = os.environ.get("ZENODO_ENV", "local").lower()
121+
VALID_ENVS = ["local", "dev", "qa", "production"]
122+
if ZENODO_ENV not in VALID_ENVS:
123+
raise ValueError(f"ZENODO_ENV is set to an invalid value: {ZENODO_ENV}\nExpected one of {VALID_ENVS}")
124+
125+
IS_LOCAL_DEV = ZENODO_ENV == "local"
121126

122127

123128
# Flask-SQLAlchemy
@@ -236,64 +241,65 @@ FILES_REST_CHECKSUM_VERIFICATION_URI_PREFIXES = {
236241
"root://eosmedia.cern.ch//eos/media/zenodo/prod",
237242
}
238243

239-
CELERY_TASK_ROUTES = {
240-
# Indexing
241-
"invenio_communities.fixtures.tasks.reindex_featured_entries": {
242-
"queue": "indexing"
243-
},
244-
"invenio_indexer.tasks.delete_record": {"queue": "indexing"},
245-
"invenio_indexer.tasks.index_record": {"queue": "indexing"},
246-
"invenio_indexer.tasks.process_bulk_queue": {"queue": "indexing"},
247-
"invenio_rdm_records.services.tasks.reindex_stats": {"queue": "indexing"},
248-
"invenio_records_resources.tasks.manage_indexer_queues": {"queue": "indexing"},
249-
"invenio_users_resources.services.domains.tasks.reindex_domains": {
250-
"queue": "indexing"
251-
},
252-
"invenio_users_resources.services.groups.tasks.reindex_groups": {
253-
"queue": "indexing"
254-
},
255-
"invenio_users_resources.services.groups.tasks.unindex_groups": {
256-
"queue": "indexing"
257-
},
258-
"invenio_users_resources.services.users.tasks.reindex_users": {"queue": "indexing"},
259-
"invenio_users_resources.services.users.tasks.unindex_users": {"queue": "indexing"},
260-
# Low
261-
"invenio_accounts.tasks.clean_session_table": {"queue": "low"},
262-
"invenio_files_rest.tasks.clear_orphaned_files": {"queue": "low"},
263-
"invenio_files_rest.tasks.remove_expired_multipartobjects": {"queue": "low"},
264-
"invenio_files_rest.tasks.remove_file_data": {"queue": "low"},
265-
"invenio_files_rest.tasks.verify_checksum": {"queue": "low"},
266-
"invenio_rdm_records.services.iiif.tasks.cleanup_tiles_file": {"queue": "low"},
267-
"invenio_rdm_records.services.iiif.tasks.generate_tiles": {"queue": "low"},
268-
"invenio_swh.tasks.cleanup_depositions": {"queue": "low"},
269-
"invenio_vocabularies.datastreams.tasks.write_entry": {"queue": "low"},
270-
"invenio_vocabularies.datastreams.tasks.write_many_entry": {"queue": "low"},
271-
"zenodo_rdm.openaire.tasks.openaire_delete": {"queue": "low"},
272-
# Spam
273-
"invenio_communities.requests.user_moderation.tasks.delete_community": {
274-
"queue": "spam"
275-
},
276-
"invenio_communities.requests.user_moderation.tasks.restore_community": {
277-
"queue": "spam"
278-
},
279-
"invenio_rdm_records.requests.user_moderation.tasks.delete_record": {
280-
"queue": "spam"
281-
},
282-
"invenio_rdm_records.requests.user_moderation.tasks.restore_record": {
283-
"queue": "spam"
284-
},
285-
"invenio_rdm_records.requests.user_moderation.tasks.user_block_cleanup": {
286-
"queue": "spam"
287-
},
288-
"invenio_rdm_records.requests.user_moderation.tasks.user_restore_cleanup": {
289-
"queue": "spam"
290-
},
291-
"invenio_users_resources.services.users.tasks.execute_moderation_actions": {
292-
"queue": "spam"
293-
},
294-
"zenodo_rdm.moderation.tasks.run_moderation_handlers": {"queue": "spam"},
295-
"zenodo_rdm.moderation.tasks.update_moderation_request": {"queue": "spam"},
296-
}
244+
if not IS_LOCAL_DEV:
245+
CELERY_TASK_ROUTES = {
246+
# Indexing
247+
"invenio_communities.fixtures.tasks.reindex_featured_entries": {
248+
"queue": "indexing"
249+
},
250+
"invenio_indexer.tasks.delete_record": {"queue": "indexing"},
251+
"invenio_indexer.tasks.index_record": {"queue": "indexing"},
252+
"invenio_indexer.tasks.process_bulk_queue": {"queue": "indexing"},
253+
"invenio_rdm_records.services.tasks.reindex_stats": {"queue": "indexing"},
254+
"invenio_records_resources.tasks.manage_indexer_queues": {"queue": "indexing"},
255+
"invenio_users_resources.services.domains.tasks.reindex_domains": {
256+
"queue": "indexing"
257+
},
258+
"invenio_users_resources.services.groups.tasks.reindex_groups": {
259+
"queue": "indexing"
260+
},
261+
"invenio_users_resources.services.groups.tasks.unindex_groups": {
262+
"queue": "indexing"
263+
},
264+
"invenio_users_resources.services.users.tasks.reindex_users": {"queue": "indexing"},
265+
"invenio_users_resources.services.users.tasks.unindex_users": {"queue": "indexing"},
266+
# Low
267+
"invenio_accounts.tasks.clean_session_table": {"queue": "low"},
268+
"invenio_files_rest.tasks.clear_orphaned_files": {"queue": "low"},
269+
"invenio_files_rest.tasks.remove_expired_multipartobjects": {"queue": "low"},
270+
"invenio_files_rest.tasks.remove_file_data": {"queue": "low"},
271+
"invenio_files_rest.tasks.verify_checksum": {"queue": "low"},
272+
"invenio_rdm_records.services.iiif.tasks.cleanup_tiles_file": {"queue": "low"},
273+
"invenio_rdm_records.services.iiif.tasks.generate_tiles": {"queue": "low"},
274+
"invenio_swh.tasks.cleanup_depositions": {"queue": "low"},
275+
"invenio_vocabularies.datastreams.tasks.write_entry": {"queue": "low"},
276+
"invenio_vocabularies.datastreams.tasks.write_many_entry": {"queue": "low"},
277+
"zenodo_rdm.openaire.tasks.openaire_delete": {"queue": "low"},
278+
# Spam
279+
"invenio_communities.requests.user_moderation.tasks.delete_community": {
280+
"queue": "spam"
281+
},
282+
"invenio_communities.requests.user_moderation.tasks.restore_community": {
283+
"queue": "spam"
284+
},
285+
"invenio_rdm_records.requests.user_moderation.tasks.delete_record": {
286+
"queue": "spam"
287+
},
288+
"invenio_rdm_records.requests.user_moderation.tasks.restore_record": {
289+
"queue": "spam"
290+
},
291+
"invenio_rdm_records.requests.user_moderation.tasks.user_block_cleanup": {
292+
"queue": "spam"
293+
},
294+
"invenio_rdm_records.requests.user_moderation.tasks.user_restore_cleanup": {
295+
"queue": "spam"
296+
},
297+
"invenio_users_resources.services.users.tasks.execute_moderation_actions": {
298+
"queue": "spam"
299+
},
300+
"zenodo_rdm.moderation.tasks.run_moderation_handlers": {"queue": "spam"},
301+
"zenodo_rdm.moderation.tasks.update_moderation_request": {"queue": "spam"},
302+
}
297303

298304
# Flask-Babel
299305
# ===========

0 commit comments

Comments
 (0)