Analyse de l’état de l’API

# Activate multi-output in notebook
from IPython.core.interactiveshell import InteractiveShell

InteractiveShell.ast_node_interactivity = "all"

Etat du cache


status_cache

 status_cache ()
print(status_cache())
True

## Etat de la file d’attente

# cache.cache.llen(REDIS_QUEUE_NAME)
# reform_base = ReformeSocioFiscale(
#     base=2022,
#     amendement={},
#     output_variables=["impot_revenu_restant_a_payer"],
#     quantile_nb=0,
# )
# task_id = "status_simu"
# msg = {"jobid": task_id, "reform": reform_base.json()}
# for i in range(7):
#     _ = cache.cache.rpush(REDIS_QUEUE_NAME, json.dumps(msg))
#     _ = cache.cache.expire(REDIS_QUEUE_NAME, 60)
# cache.cache.llen(REDIS_QUEUE_NAME)

status_queue

 status_queue ()
if status_cache():
    print(status_queue())
True

Etat des calculs de simulation


status_simu

 status_simu ()
print(await status_simu())

Version d’OpenFisca


status_version_of

 status_version_of ()
print(status_version_of())
['openfisca-france', '153.3.1']

Version du projet simu-etat


get_commit_hash

 get_commit_hash ()

status_version_projet

 status_version_projet ()
print(status_version_projet())
80874de

Status


get_status

 get_status ()
print(await get_status())
cache=True queue=True simulations=True version_openfisca=['openfisca-france', '153.3.1'] last_commit='80874de'