Method getWorkflowID

flow/cmd/handler.go:650–661

(ctx context.Context, flowJobName string)

}

func (h *FlowRequestHandler) getWorkflowID(ctx context.Context, flowJobName string) (string, error) {
	q := "SELECT workflow_id FROM flows WHERE name = $1"
	var workflowID string
	if err := h.pool.QueryRow(ctx, q, flowJobName).Scan(&workflowID); err != nil {
		if errors.Is(err, pgx.ErrNoRows) {
			return "", exceptions.NewNotFoundError(fmt.Errorf("flow job %s not found", flowJobName))
		}
		return "", fmt.Errorf("unable to get workflowID for flow job %s: %w", flowJobName, err)
	}

	return workflowID, nil
}

func (h *FlowRequestHandler) resyncByRecreatingFlow(
	ctx context.Context,