Merge pull request #1590 from memphisdev/bugfix-RND-408-remove-statio…

…n-with-attached-function-actually-not-deleted

bugfix-RND-408-remove-station-with-attached-function-actually-not-deleted

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
 	}

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
+}

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
 }