@@ -47,13 +47,13 @@ localstack_pod=$(kubectl get pods --selector app=localstack --field-selector="st
47
47
-o go-template --template ' {{range .items}}{{.metadata.name}} {{.metadata.creationTimestamp}}{{"\n"}}{{end}}' \
48
48
| awk ' $2 >= "' " ${START_TIME// +0000/ Z} " ' " { print $1 }' )
49
49
echo " 🥑 Using localstack pod ${localstack_pod} "
50
- run_instances_resp=$( kubectl exec -it " ${localstack_pod} " -- bash -c " ${RUN_INSTANCE_CMD} " )
50
+ run_instances_resp=$( kubectl exec -i " ${localstack_pod} " -- bash -c " ${RUN_INSTANCE_CMD} " )
51
51
private_dns_name=$( echo " ${run_instances_resp} " | jq -r ' .Instances[] .PrivateDnsName' )
52
52
instance_id=$( echo " ${run_instances_resp} " | jq -r ' .Instances[] .InstanceId' )
53
53
echo " 🥑 Started mock EC2 instance (${instance_id} ) w/ private DNS name: ${private_dns_name} "
54
54
55
55
CREATE_SQS_CMD=" awslocal sqs create-queue --queue-name " ${CLUSTER_NAME} -queue" --attributes MessageRetentionPeriod=300 --region ${AWS_REGION} "
56
- queue_url=$( kubectl exec -it " ${localstack_pod} " -- bash -c " ${CREATE_SQS_CMD} " | jq -r .QueueUrl)
56
+ queue_url=$( kubectl exec -i " ${localstack_pod} " -- bash -c " ${CREATE_SQS_CMD} " | jq -r .QueueUrl)
57
57
58
58
echo " 🥑 Created SQS Queue ${queue_url} "
59
59
146
146
147
147
REBALANCE_EVENT_ONE_LINE=$( echo " ${REBALANCE_EVENT} " | tr -d ' \n' | sed ' s/\"/\\"/g' )
148
148
SEND_SQS_CMD=" awslocal sqs send-message --queue-url ${queue_url} --message-body \" ${REBALANCE_EVENT_ONE_LINE} \" --region ${AWS_REGION} "
149
- kubectl exec -it " ${localstack_pod} " -- bash -c " ${SEND_SQS_CMD} "
149
+ kubectl exec -i " ${localstack_pod} " -- bash -c " ${SEND_SQS_CMD} "
150
150
echo " ✅ Sent Rebalance Recommendation to SQS queue: ${queue_url} "
151
151
152
152
GET_ATTRS_SQS_CMD=" awslocal sqs get-queue-attributes --queue-url ${queue_url} --attribute-names All --region ${AWS_REGION} "
@@ -172,8 +172,8 @@ for i in $(seq 1 $TAINT_CHECK_CYCLES); do
172
172
not_evicted=1
173
173
fi
174
174
175
- if [[ ${tainted} -eq 1 && $( kubectl exec -it " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} " | jq ' (.Attributes.ApproximateNumberOfMessagesNotVisible|tonumber) + (.Attributes.ApproximateNumberOfMessages|tonumber)' ) -eq 0 ]]; then
176
- kubectl exec -it " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} "
175
+ if [[ ${tainted} -eq 1 && $( kubectl exec -i " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} " | jq ' (.Attributes.ApproximateNumberOfMessagesNotVisible|tonumber) + (.Attributes.ApproximateNumberOfMessages|tonumber)' ) -eq 0 ]]; then
176
+ kubectl exec -i " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} "
177
177
echo " ✅ Verified the message was deleted from the queue after processing!"
178
178
message_deleted=1
179
179
break
220
220
221
221
SPOT_EVENT_ONE_LINE=$( echo " ${SPOT_EVENT} " | tr -d ' \n' | sed ' s/\"/\\"/g' )
222
222
SEND_SQS_CMD=" awslocal sqs send-message --queue-url ${queue_url} --message-body \" ${SPOT_EVENT_ONE_LINE} \" --region ${AWS_REGION} "
223
- kubectl exec -it " ${localstack_pod} " -- bash -c " ${SEND_SQS_CMD} "
223
+ kubectl exec -i " ${localstack_pod} " -- bash -c " ${SEND_SQS_CMD} "
224
224
echo " ✅ Sent Spot Interruption Event to SQS queue: ${queue_url} "
225
225
GET_ATTRS_SQS_CMD=" awslocal sqs get-queue-attributes --queue-url ${queue_url} --attribute-names All --region ${AWS_REGION} "
226
226
@@ -232,8 +232,8 @@ for i in $(seq 1 $TAINT_CHECK_CYCLES); do
232
232
evicted=1
233
233
fi
234
234
235
- if [[ ${evicted} -eq 1 && $( kubectl exec -it " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} " | jq ' (.Attributes.ApproximateNumberOfMessagesNotVisible|tonumber) + (.Attributes.ApproximateNumberOfMessages|tonumber)' ) -eq 0 ]]; then
236
- kubectl exec -it " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} "
235
+ if [[ ${evicted} -eq 1 && $( kubectl exec -i " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} " | jq ' (.Attributes.ApproximateNumberOfMessagesNotVisible|tonumber) + (.Attributes.ApproximateNumberOfMessages|tonumber)' ) -eq 0 ]]; then
236
+ kubectl exec -i " ${localstack_pod} " -- bash -c " ${GET_ATTRS_SQS_CMD} "
237
237
echo " ✅ Verified the message was deleted from the queue after processing!"
238
238
echo " ✅ Rebalance Recommendation SQS Test Passed $CLUSTER_NAME ! ✅"
239
239
exit 0
0 commit comments