|
9 | 9 | logging.basicConfig(level=logging.INFO, format="%(asctime)s %(levelname)s %(message)s") |
10 | 10 | logger = logging.getLogger(__name__) |
11 | 11 |
|
12 | | -PGHOST = os.environ.get("PGHOST", "database_postgres") |
13 | | -PGPORT = os.environ.get("PGPORT", "5432") |
14 | | -PGDATABASE = os.environ.get("PGDATABASE", "planexe") |
15 | | -PGUSER = os.environ.get("PGUSER", "planexe") |
16 | | -PGPASSWORD = os.environ.get("PGPASSWORD", "planexe") |
| 12 | +POSTGRES_HOST = os.environ.get("PLANEXE_POSTGRES_HOST", "database_postgres") |
| 13 | +POSTGRES_PORT = os.environ.get("PLANEXE_POSTGRES_PORT", "5432") |
| 14 | +POSTGRES_DB = os.environ.get("PLANEXE_POSTGRES_DB", "planexe") |
| 15 | +POSTGRES_USER = os.environ.get("PLANEXE_POSTGRES_USER", "planexe") |
| 16 | +POSTGRES_PASSWORD = os.environ.get("PLANEXE_POSTGRES_PASSWORD", "planexe") |
17 | 17 | API_KEY = os.environ.get("PLANEXE_DATABASE_WORKER_API_KEY", "") |
18 | 18 | # Railway injects PORT; fall back to PLANEXE_DATABASE_WORKER_PORT for Docker Compose. |
19 | 19 | PORT = int(os.environ.get("PORT") or os.environ.get("PLANEXE_DATABASE_WORKER_PORT", "8002")) |
@@ -66,15 +66,15 @@ def do_GET(self): |
66 | 66 | logger.info("Starting database backup: %s (%s)", filename, "zstd" if _HAS_ZSTD else "gzip") |
67 | 67 |
|
68 | 68 | env = os.environ.copy() |
69 | | - env["PGPASSWORD"] = PGPASSWORD |
| 69 | + env["PGPASSWORD"] = POSTGRES_PASSWORD # pg_dump reads PGPASSWORD from env |
70 | 70 |
|
71 | 71 | proc = subprocess.Popen( |
72 | 72 | [ |
73 | 73 | "pg_dump", |
74 | | - "-h", PGHOST, |
75 | | - "-p", PGPORT, |
76 | | - "-U", PGUSER, |
77 | | - "-d", PGDATABASE, |
| 74 | + "-h", POSTGRES_HOST, |
| 75 | + "-p", POSTGRES_PORT, |
| 76 | + "-U", POSTGRES_USER, |
| 77 | + "-d", POSTGRES_DB, |
78 | 78 | "--no-owner", |
79 | 79 | "--no-privileges", |
80 | 80 | "-Z", compress_flag, |
|
0 commit comments