What to do
Fetch enrollment data from GCS and update experiments daily at 8am.
Location: experimenter/experimenter/jetstream/
Deliverables
ENROLLMENT_ALERTS_FOLDER = "enrollment_alerts"
def get_enrollment_alert_data():
"""Fetch from GCS path: enrollment_alerts/enrollment_alerts_latest.json"""
@app.task
@metrics.timer_decorator("fetch_enrollment_alert_data")
def fetch_enrollment_alert_data():
"""Fetch data, update all experiments' enrollment_alert_data field"""
"fetch_enrollment_alert_data": {
"task": "experimenter.jetstream.tasks.fetch_enrollment_alert_data",
"schedule": crontab(minute=0, hour=8), # 8am UTC daily
}
Acceptance Criteria
┆Issue is synchronized with this Jira Task
What to do
Fetch enrollment data from GCS and update experiments daily at 8am.
Location:
experimenter/experimenter/jetstream/Deliverables
client.py:tasks.py:settings.py(CELERY_BEAT_SCHEDULE):Acceptance Criteria
┆Issue is synchronized with this Jira Task