set sql_mode = ANSI. It was this or adding template parameter for tab…

…le identifier

flow/connectors/mysql/mysql.go

@@ -92,6 +92,7 @@ func (c *MySqlConnector) Execute(ctx context.Context, cmd string, args ...interf
 			if err != nil {
 				return nil, fmt.Errorf("failed to connect to mysql server: %w", err)
 			}
+			c.conn.Execute("SET sql_mode = ANSI")
 		}
 
 		rs, err := c.conn.Execute(cmd, args...)

flow/middleware/oauth.go

@@ -83,7 +83,7 @@ func AuthGrpcMiddleware(unauthenticatedMethods []string) (grpc.UnaryServerInterc
 			_, err := validateRequestToken(authHeader, cfg.OauthJwtCustomClaims, ip...)
 			if err != nil {
 				slog.Debug("Failed to validate request token", slog.String("method", info.FullMethod), slog.Any("error", err))
-				return nil, status.Errorf(codes.Unauthenticated, "%s", err.Error())
+				return nil, status.Error(codes.Unauthenticated, err.Error())
 			}
 		}
 

flow/workflows/qrep_flow.go

@@ -223,8 +223,7 @@ func (q *QRepPartitionFlowExecution) replicatePartitions(ctx workflow.Context,
 
 // getPartitionWorkflowID returns the child workflow ID for a new sync flow.
 func (q *QRepFlowExecution) getPartitionWorkflowID(ctx workflow.Context) string {
-	id := GetUUID(ctx)
-	return fmt.Sprintf("qrep-part-%s-%s", q.config.FlowJobName, id)
+	return fmt.Sprintf("qrep-part-%s-%s", q.config.FlowJobName, GetUUID(ctx))
 }
 
 // startChildWorkflow starts a single child workflow.
@@ -266,11 +265,10 @@ func (q *QRepFlowExecution) processPartitions(
 
 	partitionWorkflows := make([]workflow.Future, 0, len(batches))
 	for i, parts := range batches {
-		batch := &protos.QRepPartitionBatch{
+		future := q.startChildWorkflow(ctx, &protos.QRepPartitionBatch{
 			Partitions: parts,
 			BatchId:    int32(i + 1),
-		}
-		future := q.startChildWorkflow(ctx, batch)
+		})
 		partitionWorkflows = append(partitionWorkflows, future)
 	}