(ctx context.Context, flowJobName string)
| 79 | } |
| 80 | |
| 81 | func (h *FlowRequestHandler) cdcJobEntryExists(ctx context.Context, flowJobName string) (bool, error) { |
| 82 | var exists bool |
| 83 | err := h.pool.QueryRow(ctx, `SELECT EXISTS(SELECT 1 FROM flows WHERE name = $1)`, flowJobName).Scan(&exists) |
| 84 | return exists, err |
| 85 | } |
| 86 | |
| 87 | func (h *FlowRequestHandler) createCdcJobEntry(ctx context.Context, |
| 88 | connectionConfigs *protos.FlowConnectionConfigsCore, workflowID string, idempotent bool, |
no test coverage detected