Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions builders/server/core/api/routes.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""HTTP endpoint handlers for the public and authenticated routers."""

from datetime import datetime

import structlog
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/definitions/always_open.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""AlwaysOpenCalendar: accepts any timestamp regardless of date or time."""

from datetime import datetime, timedelta

from core.calendars.interface import Calendar
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/definitions/everyday.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""EverydayCalendar ('everyday'): accepts every day; the default calendar."""

from datetime import datetime, timedelta

from core.calendars.interface import Calendar
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/definitions/nyse_daily.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""NyseDailyCalendar: registered as 'nyse-daily', accepts NYSE trading days only."""

from datetime import datetime, timedelta

import exchange_calendars as xcals
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/definitions/weekday.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""WeekdayCalendar: registered as 'weekday', accepts Monday through Friday only."""

from datetime import datetime, timedelta

from core.calendars.interface import Calendar
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/interface.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""The Calendar ABC defining which timestamps are valid for a dataset."""

from abc import ABC, abstractmethod
from datetime import datetime, timedelta

Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/registry.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""CALENDARS_MAP: registry mapping calendar name to Calendar instance."""

from core.calendars.definitions.always_open import AlwaysOpenCalendar
from core.calendars.definitions.everyday import EverydayCalendar
from core.calendars.definitions.nyse_daily import NyseDailyCalendar
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/calendars/utils.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Shared helpers for calendar implementations."""

from datetime import datetime


Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/db/connection.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Postgres connection pool lifecycle and per-request connection access."""

import structlog
from psycopg_pool import ConnectionPool

Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/db/datasets.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""SQL queries for the datasets table: existence, reads, and bulk insert."""

from collections import defaultdict
from datetime import datetime

Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/runtime/config.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Parses and validates config.toml into DatasetConfig; owns SCRIPTS_DIR resolution."""

import os
import re
from dataclasses import dataclass
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/runtime/loader.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Dynamically imports a builder module from its script directory."""

import importlib.util
import sys
from collections.abc import Callable
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/runtime/registry.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Startup config preload + in-memory registry; validates the dependency graph."""

import tomllib
from collections.abc import Generator
from pathlib import Path
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/runtime/runner.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Runs a builder in an isolated subprocess with retry, using its venv if present."""

import subprocess
import sys
import time
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/runtime/validator.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Validates builder output rows against the dataset's [schema] declaration."""

from core.runtime.config import SchemaType


Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/service/builder.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Public build API: build_dataset() and get_data(); selects the store."""

from dataclasses import dataclass
from datetime import datetime

Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/service/catalog.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""list_datasets(): registered datasets annotated with DB data presence."""

from dataclasses import dataclass

import core.db.datasets
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/service/locks.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Per-dataset build lock registry serializing concurrent builds of the same dataset."""

import threading

_lock_map: dict[tuple[str, str], threading.Lock] = {}
Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/service/models.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Build data types: JobDescriptor, JobResult, and BuildPlan."""

from dataclasses import dataclass
from datetime import datetime

Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/utils/retry.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""Generic retry-with-exponential-backoff helper used to wrap flaky operations."""

import time
from collections.abc import Callable

Expand Down
2 changes: 2 additions & 0 deletions builders/server/core/utils/semver.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""SemVer parsing and comparison (strict major.minor.patch, no leading zeros)."""

import re
from dataclasses import dataclass

Expand Down
2 changes: 2 additions & 0 deletions builders/server/main.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
"""FastAPI entrypoint: builds the app, mounts routers, runs the lifespan."""

import os
import uuid
from collections.abc import AsyncIterator
Expand Down
Loading