From 0795f96be557acb7a4f80351ad06ef712af7e444 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Mon, 1 Jan 2024 23:27:23 +0200 Subject: [PATCH] fix removeStationResources --- db/db.go | 2 +- db/db_cloud.go | 4 ++++ server/memphis_handlers_stations.go | 5 +++++ 3 files changed, 10 insertions(+), 1 deletion(-) diff --git a/db/db.go b/db/db.go index b0ccdc6f9..fc8c9a2a6 100644 --- a/db/db.go +++ b/db/db.go @@ -2009,7 +2009,7 @@ func DeleteStationsByNames(stationNames []string, tenantName string) error { if tenantName != conf.GlobalAccount { tenantName = strings.ToLower(tenantName) } - _, err = conn.Conn().Query(ctx, stmt.Name, stationNames, tenantName) + _, err = conn.Conn().Exec(ctx, stmt.Name, stationNames, tenantName) if err != nil { return err } diff --git a/db/db_cloud.go b/db/db_cloud.go index ffba68a68..2aaea568b 100644 --- a/db/db_cloud.go +++ b/db/db_cloud.go @@ -61,3 +61,7 @@ func DeleteAllTestEvents(tenantName string) error { func DeleteScheduledFunctionWorkersByTenant(tenantName string) error { return nil } + +func DeleteScheduledFunctionWorkersByStationId(stationId int, tenantName string) error { + return nil +} diff --git a/server/memphis_handlers_stations.go b/server/memphis_handlers_stations.go index 3a22b2e24..ce5e5e700 100644 --- a/server/memphis_handlers_stations.go +++ b/server/memphis_handlers_stations.go @@ -187,6 +187,11 @@ func removeStationResources(s *Server, station models.Station, shouldDeleteStrea return err } + err = db.DeleteScheduledFunctionWorkersByStationId(station.ID, station.TenantName) + if err != nil { + return err + } + return nil }