Function track_feature_evaluations_by_environment

api/app_analytics/tasks.py:98–114

(
    **kwargs: Unpack[TrackFeatureEvaluationsByEnvironmentKwargs],
)

@register_task_handler()
def track_feature_evaluations_by_environment(
    **kwargs: Unpack[TrackFeatureEvaluationsByEnvironmentKwargs],
) -> None:
    environment_id = kwargs["environment_id"]
    feature_evaluations = kwargs["feature_evaluations"]
    if settings.USE_POSTGRES_FOR_ANALYTICS:
        FeatureEvaluationRaw.objects.bulk_create(
            map_feature_evaluation_data_to_feature_evaluation_raw(
                environment_id=environment_id,
                feature_evaluations=feature_evaluations,
            )
        )
    elif settings.INFLUXDB_TOKEN:
        track_feature_evaluation_influxdb(
            environment_id=environment_id,
            feature_evaluations=feature_evaluations,
        )


@register_task_handler()