diff --git a/k8s/welearn-datastack/templates/updateMaterializedViews/workflow-template-refresh-materialized-views.yaml b/k8s/welearn-datastack/templates/updateMaterializedViews/workflow-template-refresh-materialized-views.yaml index 8bdb8db..d695c93 100644 --- a/k8s/welearn-datastack/templates/updateMaterializedViews/workflow-template-refresh-materialized-views.yaml +++ b/k8s/welearn-datastack/templates/updateMaterializedViews/workflow-template-refresh-materialized-views.yaml @@ -20,6 +20,10 @@ spec: envFrom: - configMapRef: name: {{ .name }} + env: + - name: VIEW_NAME + value: >- + {{ print "{{inputs.parameters.view_name}}" }} args: - python - -m diff --git a/welearn_datastack/nodes_workflow/UpdateMaterializedView/update_materialized_view.py b/welearn_datastack/nodes_workflow/UpdateMaterializedView/update_materialized_view.py index 5cf5fef..0f2482d 100644 --- a/welearn_datastack/nodes_workflow/UpdateMaterializedView/update_materialized_view.py +++ b/welearn_datastack/nodes_workflow/UpdateMaterializedView/update_materialized_view.py @@ -45,7 +45,7 @@ def update_materialized_view(view_name: str) -> None: def main(): - view_name = os.getenv("VIEW_NAME", "document_related.qty_document_in_qdrant") + view_name = os.getenv("VIEW_NAME", None) if not view_name: logger.error("VIEW_NAME environment variable is not set.") raise ValueError("VIEW_NAME environment variable is required.")