add use_predicted_traffic

source/jormungandr/jormungandr/instance.py

@@ -859,6 +859,8 @@ def additional_parameters(self):
     co2_emission_car_value = _make_property_getter('co2_emission_car_value')
     co2_emission_car_unit = _make_property_getter('co2_emission_car_unit')
 
+    use_predicted_traffic = _make_property_getter('use_predicted_traffic')
+
     def get_pt_planner(self, pt_planner_id=None):
         pt_planner_id = pt_planner_id or self.default_pt_planner
         return self._pt_planner_manager.get_pt_planner(pt_planner_id)

source/jormungandr/jormungandr/interfaces/v1/Journeys.py

@@ -883,6 +883,9 @@ def _set_specific_params(mod):
             if args.get('_loki_compute_pt_journey_fare') is None:
                 args['_loki_compute_pt_journey_fare'] = mod.loki_compute_pt_journey_fare
 
+            if args.get('_use_predicted_traffic') is None:
+                args['_use_predicted_traffic'] = mod.use_predicted_traffic
+
         # When computing 'same_journey_schedules'(is_journey_schedules=True), some parameters need to be overridden
         # because they are contradictory to the request
         if args.get("is_journey_schedules"):

source/jormungandr/jormungandr/interfaces/v1/journey_common.py

@@ -848,6 +848,12 @@ def __init__(self, output_type_serializer):
             hidden=True,
             help="whether or not to use heuristic to optimized path searching in loki, used in loki exclusively",
         )
+        parser_get.add_argument(
+            "_use_predicted_traffic",
+            type=BooleanType(),
+            hidden=True,
+            help="whether or not to use predicted/historical traffic data for routing, it affects only car/car_no_park mode in Asgard",
+        )
 
     def parse_args(self, region=None, uri=None):
         args = self.parsers['get'].parse_args()

source/jormungandr/jormungandr/street_network/asgard.py

@@ -199,6 +199,7 @@ def _create_sn_routing_matrix_request(
 
         req.sn_routing_matrix.datetime = request["datetime"]
         req.sn_routing_matrix.use_excluded_zones = request["_use_excluded_zones"]
+        req.sn_routing_matrix.use_predicted_traffic = request["_use_predicted_traffic"]
 
         # Asgard/Valhalla walking
         req.sn_routing_matrix.streetnetwork_params.walking_destination_only_penalty = request[
@@ -368,6 +369,7 @@ def _create_direct_path_request(
         req.direct_path.datetime = fallback_extremity.datetime
         req.direct_path.clockwise = fallback_extremity.represents_start
         req.direct_path.use_excluded_zones = request["_use_excluded_zones"]
+        req.direct_path.use_predicted_traffic = request["_use_predicted_traffic"]
         profiles = [
             DirectPathProfile(
                 bike_use_roads=request['bike_use_roads'],

source/navitiacommon/navitiacommon/default_values.py

@@ -254,6 +254,8 @@
 co2_emission_car_value = 184.0  # gEC by Km
 co2_emission_car_unit = 'gEC'
 
+use_predicted_traffic = False
+
 
 def get_value_or_default(attr, instance, instance_name):
     if not instance or getattr(instance, attr, None) == None:

source/navitiacommon/navitiacommon/models/__init__.py

@@ -771,6 +771,13 @@ class Instance(db.Model):  # type: ignore
         server_default=str(default_values.co2_emission_car_unit),
     )
 
+    use_predicted_traffic = db.Column(
+        db.Boolean,
+        default=default_values.use_predicted_traffic,
+        nullable=False,
+        server_default=str(default_values.use_predicted_traffic),
+    )
+
     def __init__(self, name=None, is_free=False, authorizations=None, jobs=None):
         self.name = name
         self.is_free = is_free

source/tyr/migrations/versions/fd13bb348665_add_use_predicted_traffic.py

@@ -0,0 +1,29 @@
+"""add use_predicted_traffic
+
+Revision ID: fd13bb348665
+Revises: d7ff7aea17d9
+Create Date: 2024-10-10 15:14:54.523574
+
+"""
+
+# revision identifiers, used by Alembic.
+revision = 'fd13bb348665'
+down_revision = 'd7ff7aea17d9'
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column(
+        'instance', sa.Column('use_predicted_traffic', sa.Boolean(), server_default='False', nullable=False)
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('instance', 'use_predicted_traffic')
+    # ### end Alembic commands ###