Enable dynamic filter to be updated from dfp - implicit configuration api

Author: petar-qb

vizro-core/examples/scratch_dev/app.py

@@ -1,67 +1,58 @@
-"""Test app"""
+import time
+
+import pandas as pd
 
 import vizro.models as vm
 import vizro.plotly.express as px
 from vizro import Vizro
+from vizro.managers import data_manager
 
-iris = px.data.iris()
 
-page = vm.Page(
-    title="Page with subsections",
-    layout=vm.Layout(grid=[[0, 0, 1, 1, 2, 2], [3, 3, 3, 4, 4, 4], [3, 3, 3, 4, 4, 4]]),
-    components=[
-        vm.Card(text="""Hello, this is a card with a [link](https://www.google.com)"""),
-        vm.Card(text="""Hello, this is a card with a [link](https://www.google.com)"""),
-        vm.Card(text="""Hello, this is a card with a [link](https://www.google.com)"""),
-        vm.Container(
-            title="Container I",
-            components=[
-                vm.Graph(figure=px.scatter(iris, x="sepal_width", y="sepal_length", color="species")),
-            ],
-            variant="outlined",
-        ),
-        vm.Container(
-            title="Container II",
-            components=[
-                vm.Graph(figure=px.scatter(iris, x="sepal_width", y="sepal_length", color="species")),
-            ],
-            variant="filled",
-        ),
-    ],
-)
+static_df = pd.DataFrame({
+    "species": ["artificial_species", "artificial_species", "artificial_species"],
+    "sepal_width": [4, 5, 6],
+    "sepal_length": [4, 5, 6],
+})
 
-page_two = vm.Page(
-    title="Container",
-    components=[
-        vm.Container(
-            title="Container III",
-            components=[
-                vm.Graph(figure=px.scatter(iris, x="sepal_width", y="sepal_length", color="species")),
-            ],
-        ),
-    ],
-)
 
-page_three = vm.Page(
-    title="Container Style",
+def load_data(number_of_points=150):
+    # Artificial delay to simulate data loading in production
+    print("\nLoading data...\n")
+    time.sleep(1)
+
+    return px.data.iris().head(number_of_points)
+
+
+data_manager["dynamic_df"] = load_data
+
+page_1 = vm.Page(
+    title="Update dynamic filter from DFP",
     components=[
-        vm.Container(
-            title="Container I",
-            components=[
-                vm.Graph(figure=px.scatter(iris, x="sepal_width", y="sepal_length", color="species")),
-            ],
-            variant="outlined",
-        ),
-        vm.Container(
-            title="Container II",
-            components=[
-                vm.Graph(figure=px.scatter(iris, x="sepal_width", y="sepal_length", color="species")),
-            ],
-            variant="filled",
+        vm.Graph(
+            id="dynamic_graph_1",
+            figure=px.scatter(data_frame="dynamic_df", x="sepal_width", y="sepal_length", color="species"),
         ),
+        vm.Graph(
+            figure=px.scatter(data_frame=static_df, x="sepal_width", y="sepal_length", color="species"),
+        )
     ],
+    controls=[
+        vm.Filter(column="species", selector=vm.RadioItems()),
+        vm.Parameter(
+            targets=["dynamic_graph_1.data_frame.number_of_points"],
+            selector=vm.Slider(
+                min=0,
+                max=150,
+                value=150,
+                title="Number of points",
+                step=10,
+            )
+        ),
+    ]
 )
-dashboard = vm.Dashboard(pages=[page, page_two, page_three])
+
+dashboard = vm.Dashboard(pages=[page_1])
+
 
 if __name__ == "__main__":
     Vizro().build(dashboard).run()

vizro-core/src/vizro/_vizro.py

@@ -153,7 +153,8 @@ def _pre_build():
             # Run pre_build on all filters first, then on all other models. This handles dependency between Filter
             # and Page pre_build and ensures that filters are pre-built before the Page objects that use them.
             # This is important because the Page pre_build method checks whether filters are dynamic or not, which is
-            # defined in the filter's pre_build method.
+            # defined in the filter's pre_build method. Also, the calculation of the data_frame Parameter targets
+            # depends on the filter targets, so they should be pre-built after the filters as well.
             filter.pre_build()
         for model_id in set(model_manager):
             model = model_manager[model_id]

vizro-core/src/vizro/actions/_actions_utils.py

@@ -271,10 +271,6 @@ def _get_modified_page_figures(
         else:
             figure_targets.append(target)
 
-    # TODO-NEXT: Add fetching unfiltered data for the Filter.targets as well, once dynamic filters become "targetable"
-    #  from other actions too. For example, in future, if Parameter is targeting only a single Filter.
-    #  Currently, it only works for the on_page_load because Filter.targets are indeed the part of the actions' targets.
-    #  More about the limitation: https://github.com/mckinsey/vizro/pull/879/files#r1863535516
     target_to_data_frame = _get_unfiltered_data(ctds_parameter=ctds_parameter, targets=figure_targets)
 
     # TODO: the structure here would be nicer if we could get just the ctds for a single target at one time,

vizro-core/src/vizro/actions/_callback_mapping/_callback_mapping_utils.py

@@ -97,7 +97,7 @@ def _get_action_callback_outputs(action: Action) -> dict[str, Output]:
         targets = []
 
     if action_function == _parameter.__wrapped__:
-        targets = [target.split(".")[0] for target in targets]
+        targets = [target.split(".")[0] if "." in target else target for target in targets]
 
     return {
         target: Output(

vizro-core/src/vizro/actions/_parameter_action.py

@@ -22,7 +22,7 @@ def _parameter(targets: list[str], **inputs: dict[str, Any]) -> dict[ModelID, An
         Dict mapping target component ids to modified charts/components e.g. {'my_scatter': Figure({})}
 
     """
-    target_ids: list[ModelID] = [target.split(".")[0] for target in targets]  # type: ignore[misc]
+    target_ids: list[ModelID] = [target.split(".")[0] if "." in target else target for target in targets]  # type: ignore[misc]
 
     return _get_modified_page_figures(
         ctds_filter=ctx.args_grouping["external"]["filters"],

vizro-core/src/vizro/models/_controls/parameter.py

@@ -104,7 +104,33 @@ def _set_selector_title(self):
             self.selector.title = ", ".join({target.rsplit(".")[-1] for target in self.targets})
 
     def _set_actions(self):
+        from vizro.models import Filter
+
         if not self.selector.actions:
+            page_dynamic_filters = [
+                filter
+                for filter in cast(
+                    Iterable[Filter],
+                    model_manager._get_models(Filter, page=model_manager._get_model_page(self))
+                )
+                if filter._dynamic
+            ]
+
+            filter_targets = set()
+
+            # Extend parameter targets with dynamic filters linked to the same figure.
+            # Also, include dynamic filter targets to ensure new filter options are correctly calculated
+            # and filter targets are updated when filter values change.
+            for figure_target in self.targets:
+                figure_target_id, figure_target_argument = figure_target.split(".", 1)
+                if figure_target_argument.startswith("data_frame"):
+                    for filter in page_dynamic_filters:
+                        if figure_target_id in filter.targets:
+                            filter_targets.add(filter.id)
+                            filter_targets |= set(filter.targets)
+
+            self.targets.extend(list(filter_targets))
+
             self.selector.actions = [
                 Action(id=f"{PARAMETER_ACTION_PREFIX}_{self.id}", function=_parameter(targets=self.targets))
             ]