Skip to content

Commit 7df519a

Browse files
authored
Update sample_project with default celery config (#1658)
1 parent 11c9cc2 commit 7df519a

File tree

5 files changed

+12
-8
lines changed

5 files changed

+12
-8
lines changed

.fides/celery.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
1-
event_queue_prefix = "fidesops_worker"
2-
task_default_queue = "fidesops"
1+
event_queue_prefix = "fides_worker"
2+
task_default_queue = "fides"
33
task_always_eager = true

data/config/celery.override.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
event_queue_prefix = "overridden_fidesops_worker"
2-
task_default_queue = "overridden_fidesops"
1+
event_queue_prefix = "overridden_fides_worker"
2+
task_default_queue = "overridden_fides"
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
event_queue_prefix = "fides_worker"
2+
task_default_queue = "fides"
3+
task_always_eager = true

src/fides/data/sample_project/fides.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ oauth_root_client_secret = "fidesadminsecret"
2020

2121
[execution]
2222
require_manual_request_approval = true
23+
celery_config_path = "/fides/src/fides/data/sample_project/celery.toml"
2324

2425
[cli]
2526
server_host = "fides"

tests/ops/tasks/test_celery.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,11 @@ def test_celery_default_config() -> None:
2020
celery_app = _create_celery()
2121
assert celery_app.conf["broker_url"] == CONFIG.redis.connection_url
2222
assert celery_app.conf["result_backend"] == CONFIG.redis.connection_url
23-
assert celery_app.conf["event_queue_prefix"] == "fidesops_worker"
24-
assert celery_app.conf["task_default_queue"] == "fidesops"
23+
assert celery_app.conf["event_queue_prefix"] == "fides_worker"
24+
assert celery_app.conf["task_default_queue"] == "fides"
2525

2626

2727
def test_celery_config_override() -> None:
2828
celery_app = _create_celery(config_path="data/config/celery.override.toml")
29-
assert celery_app.conf["event_queue_prefix"] == "overridden_fidesops_worker"
30-
assert celery_app.conf["task_default_queue"] == "overridden_fidesops"
29+
assert celery_app.conf["event_queue_prefix"] == "overridden_fides_worker"
30+
assert celery_app.conf["task_default_queue"] == "overridden_fides"

0 commit comments

Comments
 (0)