diff --git a/web/src/components/pipeline/NodeForm/Query.vue b/web/src/components/pipeline/NodeForm/Query.vue
index 474ed0eb4b..bd297e4291 100644
--- a/web/src/components/pipeline/NodeForm/Query.vue
+++ b/web/src/components/pipeline/NodeForm/Query.vue
@@ -37,9 +37,12 @@ along with this program. If not, see .
:disableVrlFunction="true"
:isValidSqlQuery="isValidSqlQuery"
:disableQueryTypeSelection="true"
+ :expandedLogs="expandedLogs"
+
v-model:trigger="streamRoute.trigger_condition"
v-model:sql="streamRoute.query_condition.sql"
v-model:promql="streamRoute.query_condition.promql"
+ v-model:promql_condition="streamRoute.query_condition.promql_condition"
v-model:query_type="streamRoute.query_condition.type"
v-model:aggregation="streamRoute.query_condition.aggregation"
v-model:stream_type="streamRoute.stream_type"
@@ -50,6 +53,7 @@ along with this program. If not, see .
@delete:node="openDeleteDialog"
@update:fullscreen="updateFullscreenMode"
@update:stream_type="updateStreamType"
+ @expandLog="toggleExpandLog"
class="q-mt-sm"
/>
@@ -80,11 +84,12 @@ import { useRouter } from "vue-router";
import useStreams from "@/composables/useStreams";
import ConfirmDialog from "@/components/ConfirmDialog.vue";
import { useQuasar } from "quasar";
-import ScheduledPipeline from "@/components/pipeline/NodeForm/ScheduledPipeline.vue";
import useQuery from "@/composables/useQuery";
import searchService from "@/services/search";
import useDragAndDrop from "@/plugins/pipelines/useDnD";
+import ScheduledPipeline from "@/components/pipeline/NodeForm/ScheduledPipeline.vue";
+
const VariablesInput = defineAsyncComponent(
() => import("@/components/alerts/VariablesInput.vue"),
);
@@ -103,6 +108,11 @@ interface StreamRoute {
query_condition: {
sql: string;
promql: string | null;
+ promql_condition: {
+ column: string;
+ operator: string;
+ value: any;
+ } | null;
type: string;
aggregation: {
group_by: string[];
@@ -161,6 +171,7 @@ const filteredColumns: any = ref([]);
const isValidSqlQuery = ref(true);
+const expandedLogs = ref([]);
const validateSqlQueryPromise = ref
>();
const scheduledPipelineRef = ref(null);
@@ -212,6 +223,11 @@ const getDefaultStreamRoute: any = () => {
sql: "",
type: "sql",
aggregation: null,
+ promql_condition: {
+ column: "",
+ operator: "",
+ value: "",
+ },
},
trigger_condition: {
period: 15,
@@ -232,6 +248,7 @@ const getDefaultStreamRoute: any = () => {
};
onMounted(() => {
+
if (pipelineObj.isEditNode) {
streamRoute.value = pipelineObj.currentSelectedNodeData
?.data as StreamRoute;
@@ -495,6 +512,10 @@ const updateQueryType = (val: string) => {
streamRoute.value.query_condition.sql = "";
}
};
+
+const toggleExpandLog = (index: number) => {
+ expandedLogs.value = [];
+};