Make worker node optional

CHANGELOG.md

@@ -27,6 +27,8 @@ The types of changes are:
 * Parallelize CI safe checks to reduce run time [#717](https://github.com/ethyca/fidesops/pull/717)
 * Add dependabot to keep dependencies up to date [#718](https://github.com/ethyca/fidesops/pull/718)
 
+* Make running a worker node optional [#770](https://github.com/ethyca/fidesops/pull/770)
+
 ### Changed
 * Base64 encode passwords on frontend [#749](https://github.com/ethyca/fidesops/pull/749)
 

docker-compose.worker.yml

@@ -0,0 +1,22 @@
+services:
+  webserver:
+    depends_on:
+      - worker
+    environment:
+      - FIDESOPS__EXECUTION__WORKER_ENABLED=True
+
+  worker:
+    build:
+      context: .
+      dockerfile: Dockerfile.worker
+    command: fidesops worker
+    depends_on:
+      redis:
+        condition: service_started
+    restart: always
+    volumes:
+      - type: bind
+        source: ./
+        target: /fidesops
+        read_only: False
+      - /fidesops/src/fidesops.egg-info

docker-compose.yml

@@ -5,7 +5,6 @@ services:
       context: .
       dockerfile: Dockerfile.app
     depends_on:
-      - worker
       - db
       - redis
     expose:
@@ -29,6 +28,7 @@ services:
       - FIDESOPS__LOG_PII=${FIDESOPS__LOG_PII}
       - FIDESOPS__HOT_RELOAD=${FIDESOPS__HOT_RELOAD}
       - FIDESOPS__ROOT_USER__ANALYTICS_ID=${FIDESOPS__ROOT_USER__ANALYTICS_ID}
+      - FIDESOPS__EXECUTION__WORKER_ENABLED=False
 
   db:
     image: postgres:12
@@ -59,22 +59,6 @@ services:
     ports:
       - "0.0.0.0:6379:6379"
 
-  worker:
-    build:
-      context: .
-      dockerfile: Dockerfile.worker
-    command: fidesops worker
-    depends_on:
-      redis:
-        condition: service_started
-    restart: always
-    volumes:
-      - type: bind
-        source: ./
-        target: /fidesops
-        read_only: False
-      - /fidesops/src/fidesops.egg-info
-
   docs:
     build:
       context: docs/fidesops/

docs/fidesops/docs/guides/configuration_reference.md

@@ -58,6 +58,9 @@ The `fidesops.toml` file should specify the following variables:
 |`TASK_RETRY_BACKOFF` | `FIDESOPS__EXECUTION__TASK_RETRY_BACKOFF` | int | 2 | 1 | The backoff factor for retries, to space out repeated retries.
 |`REQUIRE_MANUAL_REQUEST_APPROVAL` | `FIDESOPS__EXECUTION__REQUIRE_MANUAL_REQUEST_APPROVAL` | bool | False | False | Whether privacy requests require explicit approval to execute
 |`MASKING_STRICT` | `FIDESOPS__EXECUTION__MASKING_STRICT` | bool | True | True | If MASKING_STRICT is True, we only use "update" requests to mask data. (For third-party integrations, you should define an `update` endpoint to use.)  If MASKING_STRICT is False, you are allowing fidesops to use any defined DELETE or GDPR DELETE endpoints to remove PII. In this case, you should define `delete` or `data_protection_request` endpoints for your third-party integrations.  Note that setting MASKING_STRICT to False means that data may be deleted beyond the specific data categories that you've configured in your Policy.
+|`CELERY_BROKER_URL` | `FIDESOPS__EXECUTION__CELERY_BROKER_URL` | str | redis://:testpassword@redis:6379/1 | N/A | The datastore to maintain ordered queues of tasks.
+|`CELERY_RESULT_BACKEND` | `FIDESOPS__EXECUTION__RESULT_BACKEND` | str | redis://:testpassword@redis:6379/1 | N/A | The datastore to put results from asynchronously processed tasks.
+|`WORKER_ENABLED` | `FIDESOPS__EXECUTION__WORKER_ENABLED` | bool | True | True | Whether Fidesops is running with a dedicated worker to process privacy requests asynchronously.
 |---|---|---|---|---|---|
 |`ANALYTICS_OPT_OUT` | `FIDESOPS__USER__ANALYTICS_OPT_OUT` | bool | False | False | Opt out of sending anonymous usage data to Ethyca to improve the product experience
 | Admin UI Variables|---|---|---|---|---|
@@ -98,6 +101,10 @@ TASK_RETRY_DELAY=20
 TASK_RETRY_BACKOFF=2
 REQUIRE_MANUAL_REQUEST_APPROVAL=true
 MASKING_STRICT=true
+CELERY_BROKER_URL="redis://:testpassword@redis:6379/1"
+CELERY_RESULT_BACKEND="redis://:testpassword@redis:6379/1"
+WORKER_ENABLED=true
+
 
 [root_user]
 ANALYTICS_OPT_OUT=false

fidesops.toml

@@ -34,6 +34,7 @@ REQUIRE_MANUAL_REQUEST_APPROVAL = false
 TASK_RETRY_COUNT = 0
 TASK_RETRY_DELAY = 1
 TASK_RETRY_BACKOFF = 1
+WORKER_ENABLED = false
 
 [root_user]
 ANALYTICS_OPT_OUT = false

src/fidesops/core/config.py

@@ -41,6 +41,7 @@ class ExecutionSettings(FidesSettings):
     MASKING_STRICT: bool = True
     CELERY_BROKER_URL: str = "redis://:testpassword@redis:6379/1"
     CELERY_RESULT_BACKEND: str = "redis://:testpassword@redis:6379/1"
+    WORKER_ENABLED: bool = True
 
     class Config:
         env_prefix = "FIDESOPS__EXECUTION__"

src/fidesops/main.py

@@ -1,4 +1,5 @@
 import logging
+import subprocess
 from datetime import datetime, timezone
 from pathlib import Path
 from typing import Callable, Optional
@@ -23,6 +24,7 @@
 from fidesops.core.config import config
 from fidesops.db.database import init_db
 from fidesops.schemas.analytics import Event, ExtraData
+from fidesops.tasks import start_worker
 from fidesops.tasks.scheduled.scheduler import scheduler
 from fidesops.tasks.scheduled.tasks import initiate_scheduled_request_intake
 from fidesops.util.cache import get_cache
@@ -172,6 +174,10 @@ def start_webserver() -> None:
         )
     )
 
+    if not config.execution.WORKER_ENABLED:
+        logger.info("Starting worker...")
+        subprocess.Popen(["fidesops", "worker"])
+
     logger.info("Starting web server...")
     uvicorn.run(
         "fidesops.main:app",