0d39237b3c
* upgrade to latest ruff * try to fix dep review * try to fix dep review (2) * upgrade black * upgrade black (2) * update allowed dependencies * update allowed dependencies (2) * update allowed dependencies (3) * wait between interim and final in yield test * remove previous commit, increase delay between yield * forgot to save on the time.sleep(1) removal * fix integration (maybe?) * fix pyi? * what even is going on * what is realityi? * test another fix for app harness * try to wait even longer? * force uvloop to be optional * downpin fastapi < 0.111, remove changes to test
38 lines
1.2 KiB
Python
38 lines
1.2 KiB
Python
"""Shims the real reflex app module for running backend server (uvicorn or gunicorn).
|
|
Only the app attribute is explicitly exposed.
|
|
"""
|
|
|
|
from concurrent.futures import ThreadPoolExecutor
|
|
|
|
from reflex import constants
|
|
from reflex.utils import telemetry
|
|
from reflex.utils.exec import is_prod_mode
|
|
from reflex.utils.prerequisites import get_app
|
|
|
|
if constants.CompileVars.APP != "app":
|
|
raise AssertionError("unexpected variable name for 'app'")
|
|
|
|
telemetry.send("compile")
|
|
app_module = get_app(reload=False)
|
|
app = getattr(app_module, constants.CompileVars.APP)
|
|
# For py3.8 and py3.9 compatibility when redis is used, we MUST add any decorator pages
|
|
# before compiling the app in a thread to avoid event loop error (REF-2172).
|
|
app._apply_decorated_pages()
|
|
compile_future = ThreadPoolExecutor(max_workers=1).submit(app._compile)
|
|
compile_future.add_done_callback(
|
|
# Force background compile errors to print eagerly
|
|
lambda f: f.result()
|
|
)
|
|
# Wait for the compile to finish in prod mode to ensure all optional endpoints are mounted.
|
|
if is_prod_mode():
|
|
compile_future.result()
|
|
|
|
# ensure only "app" is exposed.
|
|
del app_module
|
|
del compile_future
|
|
del get_app
|
|
del is_prod_mode
|
|
del telemetry
|
|
del constants
|
|
del ThreadPoolExecutor
|