couple more alerts

PeerDB-io · Dec 28, 2023 · ef6d01e · ef6d01e
1 parent a1896a8
commit ef6d01e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -138,6 +138,7 @@ func (a *FlowableActivity) CreateRawTable(
 
 	res, err := dstConn.CreateRawTable(config)
 	if err != nil {
+		a.Alerter.LogFlowError(ctx, config.FlowJobName, err)
 		return nil, err
 	}
 	err = monitoring.InitializeCDCFlow(ctx, a.CatalogPool, config.FlowJobName)
@@ -918,6 +919,7 @@ func (a *FlowableActivity) CreateTablesFromExisting(ctx context.Context, req *pr
 		}
 		return bqConn.CreateTablesFromExisting(req)
 	}
+	a.Alerter.LogFlowError(ctx, req.FlowJobName, err)
 	return nil, fmt.Errorf("create tables from existing is only supported on snowflake and bigquery")
 }