mirror of
https://github.com/hanzoai/insights.git
synced 2026-11-03 00:52:32 +00:00
zeekay
bc4ddf332b
Mechanically re-derived: bin/debrand runs over a fresh import of posthog/posthog@fa1a9a60d4 (2026-08-06). The pipeline (.hanzo/workflows), the Dockerfiles and bin/docker* entrypoints, compose files, LLM.md and the squashed initial migration are restored from the shipped tree, same as the previous import. The prune's import-closure guard kept 21 products the new core now imports; dropping them is a refactor now, recorded rather than forced.
42 lines
1.5 KiB
Python
42 lines
1.5 KiB
Python
"""Feature-flag gate for the APM product.
|
|
|
|
APM is unreleased, so nothing that lands here runs for a team until
|
|
``unified-apm-product`` is switched on for that team. This gates the product as
|
|
a whole. A capability that needs its own rollout, like anomaly detection, gets
|
|
its own flag layered on top of this one rather than reusing it.
|
|
|
|
The gate evaluates against the ``project`` group keyed on team ID alone, so it
|
|
needs no ``Team`` row and no database read. That matters because work landing
|
|
here is expected to run per team on a schedule, where a fetch per team per tick
|
|
would be pure overhead.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import structlog
|
|
|
|
from insights.ph_client import feature_enabled_or_false
|
|
|
|
logger = structlog.get_logger(__name__)
|
|
|
|
UNIFIED_APM_PRODUCT_FLAG = "unified-apm-product"
|
|
|
|
|
|
def is_apm_enabled(team_id: int) -> bool:
|
|
try:
|
|
return feature_enabled_or_false(
|
|
UNIFIED_APM_PRODUCT_FLAG,
|
|
str(team_id),
|
|
groups={"project": str(team_id)},
|
|
group_properties={"project": {"id": str(team_id)}},
|
|
only_evaluate_locally=False,
|
|
# Work here is scheduled per team, so leaving this on would emit a
|
|
# $feature_flag_called event for every team on every tick.
|
|
send_feature_flag_events=False,
|
|
)
|
|
except Exception:
|
|
# An unreleased product stays off when the flags service is unreachable,
|
|
# rather than defaulting on or failing the caller's run.
|
|
logger.exception("apm_feature_flag_check_failed", team_id=team_id)
|
|
return False
|