Skip to content

HYPERFLEET-790 - fix: use kubectl exec instead of kubectl run for maestro consumer creation #27

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
tzhou5 wants to merge 3 commits into
base: main
Choose a base branch
from
Open

HYPERFLEET-790 - fix: use kubectl exec instead of kubectl run for maestro consumer creation #27

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
7b5ce10
HYPERFLEET-790 - fix: use kubectl exec instead of kubectl run for mae…
tzhou5 Mar 20, 2026
01039e1
fix: use kubectl exec with retry for maestro consumer creation
tzhou5 Mar 20, 2026
0eb503e
fix: show curl error details in maestro consumer creation
tzhou5 Mar 20, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 10 additions & 13 deletions Makefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -132,19 +132,16 @@ install-maestro: check-helm check-kubectl check-maestro-namespace ## Install Mae
.PHONY: create-maestro-consumer
create-maestro-consumer: check-kubectl ## Create a Maestro consumer (requires Maestro server running)
@echo "Creating Maestro consumer '$(MAESTRO_CONSUMER)'..."
@kubectl delete pod maestro-consumer-create --namespace $(MAESTRO_NS) --kubeconfig $(KUBECONFIG) --ignore-not-found >/dev/null 2>&1
@kubectl run maestro-consumer-create --restart=Never \
--namespace $(MAESTRO_NS) \
--kubeconfig $(KUBECONFIG) \
--image=curlimages/curl:latest -- \
curl -sf -X POST \
-H "Content-Type: application/json" \
http://maestro.$(MAESTRO_NS).svc.cluster.local:8000/api/maestro/v1/consumers \
-d '{"name": "$(MAESTRO_CONSUMER)"}'
@kubectl wait --for=condition=Ready pod/maestro-consumer-create --namespace $(MAESTRO_NS) --kubeconfig $(KUBECONFIG) --timeout=60s 2>/dev/null || true
@kubectl wait --for=jsonpath='{.status.phase}'=Succeeded pod/maestro-consumer-create --namespace $(MAESTRO_NS) --kubeconfig $(KUBECONFIG) --timeout=60s
@kubectl logs maestro-consumer-create --namespace $(MAESTRO_NS) --kubeconfig $(KUBECONFIG)
@kubectl delete pod maestro-consumer-create --namespace $(MAESTRO_NS) --kubeconfig $(KUBECONFIG) --ignore-not-found >/dev/null 2>&1
@for i in 1 2 3 4 5; do \
kubectl exec deploy/maestro --namespace $(MAESTRO_NS) --kubeconfig $(KUBECONFIG) -- \
curl -sSf -X POST \
-H "Content-Type: application/json" \
http://maestro.$(MAESTRO_NS).svc.cluster.local:8000/api/maestro/v1/consumers \
-d '{"name": "$(MAESTRO_CONSUMER)"}' && exit 0; \
echo " Attempt $$i failed, retrying in 5s..."; \
sleep 5; \
done; \
echo "ERROR: failed to create Maestro consumer after 5 attempts"; exit 1
@echo ""
@echo "OK: consumer '$(MAESTRO_CONSUMER)' created"

Expand Down