We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b6805d9 commit 091bee5Copy full SHA for 091bee5
1 file changed
flow/cmd/handler.go
@@ -79,7 +79,7 @@ func (h *FlowRequestHandler) createCdcJobEntry(ctx context.Context,
79
80
if _, err := h.pool.Exec(ctx,
81
`INSERT INTO flows (workflow_id, name, source_peer, destination_peer, config_proto, status,
82
- description, source_table_identifier, destination_table_identifier) VALUES ($1,$2,$3,$4,$5,$6,'gRPC','','')`,
+ description) VALUES ($1,$2,$3,$4,$5,$6,'gRPC')`,
83
workflowID, req.ConnectionConfigs.FlowJobName, sourcePeerID, destinationPeerID, cfgBytes, protos.FlowStatus_STATUS_SETUP,
84
); err != nil {
85
return fmt.Errorf("unable to insert into flows table for flow %s: %w",
0 commit comments