Compare commits
3 Commits
v202603071
...
v202603071
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b071199895 | ||
|
|
af536f22ea | ||
|
|
c320bef83e |
@@ -26,6 +26,7 @@ RUN mkdir -p /app/data && chown -R appuser:appuser /app
|
|||||||
COPY --from=build --chown=appuser:appuser /app .
|
COPY --from=build --chown=appuser:appuser /app .
|
||||||
COPY --from=css-build /app/web/src/padelnomics/static/css/output.css ./web/src/padelnomics/static/css/output.css
|
COPY --from=css-build /app/web/src/padelnomics/static/css/output.css ./web/src/padelnomics/static/css/output.css
|
||||||
COPY --chown=appuser:appuser infra/supervisor/workflows.toml ./infra/supervisor/workflows.toml
|
COPY --chown=appuser:appuser infra/supervisor/workflows.toml ./infra/supervisor/workflows.toml
|
||||||
|
COPY --chown=appuser:appuser content/ ./content/
|
||||||
USER appuser
|
USER appuser
|
||||||
ENV PYTHONUNBUFFERED=1
|
ENV PYTHONUNBUFFERED=1
|
||||||
ENV DATABASE_PATH=/app/data/app.db
|
ENV DATABASE_PATH=/app/data/app.db
|
||||||
|
|||||||
@@ -27,6 +27,7 @@ from quart import (
|
|||||||
from ..auth.routes import role_required
|
from ..auth.routes import role_required
|
||||||
from ..core import (
|
from ..core import (
|
||||||
EMAIL_ADDRESSES,
|
EMAIL_ADDRESSES,
|
||||||
|
REPO_ROOT,
|
||||||
config,
|
config,
|
||||||
count_where,
|
count_where,
|
||||||
csrf_protect,
|
csrf_protect,
|
||||||
@@ -2182,7 +2183,7 @@ async def scenario_pdf(scenario_id: int):
|
|||||||
# Article Management
|
# Article Management
|
||||||
# =============================================================================
|
# =============================================================================
|
||||||
|
|
||||||
_ARTICLES_DIR = Path(__file__).parent.parent.parent.parent.parent / "data" / "content" / "articles"
|
_ARTICLES_DIR = REPO_ROOT / "content" / "articles"
|
||||||
_FRONTMATTER_RE = re.compile(r"^---\s*\n(.*?)\n---\s*\n", re.DOTALL)
|
_FRONTMATTER_RE = re.compile(r"^---\s*\n(.*?)\n---\s*\n", re.DOTALL)
|
||||||
|
|
||||||
|
|
||||||
@@ -2792,7 +2793,7 @@ async def article_new():
|
|||||||
(build_dir / f"{article_slug}.html").write_text(body_html)
|
(build_dir / f"{article_slug}.html").write_text(body_html)
|
||||||
|
|
||||||
# Save markdown source
|
# Save markdown source
|
||||||
md_dir = Path("data/content/articles")
|
md_dir = REPO_ROOT / "content" / "articles"
|
||||||
md_dir.mkdir(parents=True, exist_ok=True)
|
md_dir.mkdir(parents=True, exist_ok=True)
|
||||||
(md_dir / f"{article_slug}.md").write_text(body)
|
(md_dir / f"{article_slug}.md").write_text(body)
|
||||||
|
|
||||||
@@ -2863,7 +2864,7 @@ async def article_edit(article_id: int):
|
|||||||
build_dir.mkdir(parents=True, exist_ok=True)
|
build_dir.mkdir(parents=True, exist_ok=True)
|
||||||
(build_dir / f"{article['slug']}.html").write_text(body_html)
|
(build_dir / f"{article['slug']}.html").write_text(body_html)
|
||||||
|
|
||||||
md_dir = Path("data/content/articles")
|
md_dir = REPO_ROOT / "content" / "articles"
|
||||||
md_dir.mkdir(parents=True, exist_ok=True)
|
md_dir.mkdir(parents=True, exist_ok=True)
|
||||||
(md_dir / f"{article['slug']}.md").write_text(body)
|
(md_dir / f"{article['slug']}.md").write_text(body)
|
||||||
|
|
||||||
@@ -3054,7 +3055,7 @@ async def _rebuild_article(article_id: int):
|
|||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
# Manual article: re-render from markdown file
|
# Manual article: re-render from markdown file
|
||||||
md_path = Path("data/content/articles") / f"{article['slug']}.md"
|
md_path = REPO_ROOT / "content" / "articles" / f"{article['slug']}.md"
|
||||||
if not md_path.exists():
|
if not md_path.exists():
|
||||||
return
|
return
|
||||||
raw = md_path.read_text()
|
raw = md_path.read_text()
|
||||||
|
|||||||
@@ -17,14 +17,14 @@ import yaml
|
|||||||
from jinja2 import ChainableUndefined, Environment
|
from jinja2 import ChainableUndefined, Environment
|
||||||
|
|
||||||
from ..analytics import fetch_analytics
|
from ..analytics import fetch_analytics
|
||||||
from ..core import slugify, transaction, utcnow_iso
|
from ..core import REPO_ROOT, slugify, transaction, utcnow_iso
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
# ── Constants ────────────────────────────────────────────────────────────────
|
# ── Constants ────────────────────────────────────────────────────────────────
|
||||||
|
|
||||||
TEMPLATES_DIR = Path(__file__).parent / "templates"
|
TEMPLATES_DIR = Path(__file__).parent / "templates"
|
||||||
BUILD_DIR = Path("data/content/_build")
|
BUILD_DIR = REPO_ROOT / "data" / "content" / "_build"
|
||||||
|
|
||||||
# Threshold functions per template slug.
|
# Threshold functions per template slug.
|
||||||
# Return True → article should be noindex (insufficient data for quality content).
|
# Return True → article should be noindex (insufficient data for quality content).
|
||||||
|
|||||||
@@ -9,7 +9,14 @@ from jinja2 import Environment, FileSystemLoader
|
|||||||
from markupsafe import Markup
|
from markupsafe import Markup
|
||||||
from quart import Blueprint, abort, g, redirect, render_template, request
|
from quart import Blueprint, abort, g, redirect, render_template, request
|
||||||
|
|
||||||
from ..core import capture_waitlist_email, csrf_protect, feature_gate, fetch_all, fetch_one
|
from ..core import (
|
||||||
|
REPO_ROOT,
|
||||||
|
capture_waitlist_email,
|
||||||
|
csrf_protect,
|
||||||
|
feature_gate,
|
||||||
|
fetch_all,
|
||||||
|
fetch_one,
|
||||||
|
)
|
||||||
from ..i18n import get_translations
|
from ..i18n import get_translations
|
||||||
|
|
||||||
bp = Blueprint(
|
bp = Blueprint(
|
||||||
@@ -18,7 +25,7 @@ bp = Blueprint(
|
|||||||
template_folder=str(Path(__file__).parent / "templates"),
|
template_folder=str(Path(__file__).parent / "templates"),
|
||||||
)
|
)
|
||||||
|
|
||||||
BUILD_DIR = Path("data/content/_build")
|
BUILD_DIR = REPO_ROOT / "data" / "content" / "_build"
|
||||||
|
|
||||||
RESERVED_PREFIXES = (
|
RESERVED_PREFIXES = (
|
||||||
"/admin", "/auth", "/planner", "/billing", "/dashboard",
|
"/admin", "/auth", "/planner", "/billing", "/dashboard",
|
||||||
|
|||||||
@@ -27,6 +27,9 @@ from quart import g, make_response, render_template, request, session # noqa: E
|
|||||||
|
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
|
|
||||||
|
# Repo root: web/src/padelnomics/core.py → 4 levels up
|
||||||
|
REPO_ROOT = Path(__file__).parents[3]
|
||||||
|
|
||||||
|
|
||||||
def _env(key: str, default: str) -> str:
|
def _env(key: str, default: str) -> str:
|
||||||
"""Get env var, treating empty string same as unset."""
|
"""Get env var, treating empty string same as unset."""
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ from datetime import datetime, timedelta
|
|||||||
|
|
||||||
from .core import (
|
from .core import (
|
||||||
EMAIL_ADDRESSES,
|
EMAIL_ADDRESSES,
|
||||||
|
REPO_ROOT,
|
||||||
config,
|
config,
|
||||||
execute,
|
execute,
|
||||||
fetch_all,
|
fetch_all,
|
||||||
@@ -710,9 +711,8 @@ async def handle_run_extraction(payload: dict) -> None:
|
|||||||
If absent, runs all extractors via the umbrella `extract` entry point.
|
If absent, runs all extractors via the umbrella `extract` entry point.
|
||||||
"""
|
"""
|
||||||
import subprocess
|
import subprocess
|
||||||
from pathlib import Path
|
|
||||||
|
|
||||||
repo_root = Path(__file__).resolve().parents[4]
|
repo_root = REPO_ROOT
|
||||||
extractor = payload.get("extractor", "").strip()
|
extractor = payload.get("extractor", "").strip()
|
||||||
if extractor:
|
if extractor:
|
||||||
cmd_name = f"extract-{extractor.replace('_', '-')}"
|
cmd_name = f"extract-{extractor.replace('_', '-')}"
|
||||||
@@ -743,9 +743,8 @@ async def handle_run_transform(payload: dict) -> None:
|
|||||||
2-hour absolute timeout — same as extraction.
|
2-hour absolute timeout — same as extraction.
|
||||||
"""
|
"""
|
||||||
import subprocess
|
import subprocess
|
||||||
from pathlib import Path
|
|
||||||
|
|
||||||
repo_root = Path(__file__).resolve().parents[4]
|
repo_root = REPO_ROOT
|
||||||
result = await asyncio.to_thread(
|
result = await asyncio.to_thread(
|
||||||
subprocess.run,
|
subprocess.run,
|
||||||
["uv", "run", "sqlmesh", "-p", "transform/sqlmesh_padelnomics", "plan", "prod", "--auto-apply"],
|
["uv", "run", "sqlmesh", "-p", "transform/sqlmesh_padelnomics", "plan", "prod", "--auto-apply"],
|
||||||
@@ -769,9 +768,8 @@ async def handle_run_export(payload: dict) -> None:
|
|||||||
10-minute absolute timeout.
|
10-minute absolute timeout.
|
||||||
"""
|
"""
|
||||||
import subprocess
|
import subprocess
|
||||||
from pathlib import Path
|
|
||||||
|
|
||||||
repo_root = Path(__file__).resolve().parents[4]
|
repo_root = REPO_ROOT
|
||||||
result = await asyncio.to_thread(
|
result = await asyncio.to_thread(
|
||||||
subprocess.run,
|
subprocess.run,
|
||||||
["uv", "run", "python", "src/padelnomics/export_serving.py"],
|
["uv", "run", "python", "src/padelnomics/export_serving.py"],
|
||||||
@@ -791,9 +789,8 @@ async def handle_run_export(payload: dict) -> None:
|
|||||||
async def handle_run_pipeline(payload: dict) -> None:
|
async def handle_run_pipeline(payload: dict) -> None:
|
||||||
"""Run full ELT pipeline: extract → transform → export, stopping on first failure."""
|
"""Run full ELT pipeline: extract → transform → export, stopping on first failure."""
|
||||||
import subprocess
|
import subprocess
|
||||||
from pathlib import Path
|
|
||||||
|
|
||||||
repo_root = Path(__file__).resolve().parents[4]
|
repo_root = REPO_ROOT
|
||||||
|
|
||||||
steps = [
|
steps = [
|
||||||
(
|
(
|
||||||
|
|||||||
Reference in New Issue
Block a user