Skip to content

Commit

Permalink
Update localstack to latest (closes #219)
Browse files Browse the repository at this point in the history
  • Loading branch information
colmsnowplow committed Oct 10, 2022
1 parent 002b794 commit be2dd83
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 5 deletions.
5 changes: 2 additions & 3 deletions integration/docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,11 @@ version: "3"

services:
localstack:
image: localstack/localstack-light:0.11.1
image: localstack/localstack-light:1.1.0
ports:
- "4566-4568:4566-4568"
volumes:
- "./.localstack:/tmp/localstack"
- "./.localstack:/var/lib/localstack"
- "./localstack:/docker-entrypoint-initaws.d"
- "/var/run/docker.sock:/var/run/docker.sock"
logging:
Expand All @@ -15,7 +15,6 @@ services:
max-file: "10"
environment:
- SERVICES=sqs,kinesis,dynamodb,sts
- DATA_DIR=/tmp/localstack/data

pubsub:
image: bigtruedata/gcloud-pubsub-emulator
Expand Down
2 changes: 1 addition & 1 deletion pkg/source/sqs/sqs_source_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ func TestSQSSource_ReadFailure(t *testing.T) {
err = source.Read(nil)
assert.NotNil(err)
if err != nil {
assert.Equal("Failed to get SQS queue URL: AWS.SimpleQueueService.NonExistentQueue: AWS.SimpleQueueService.NonExistentQueue; see the SQS docs.\n\tstatus code: 400, request id: 00000000-0000-0000-0000-000000000000", err.Error())
assert.Contains(err.Error(), "Failed to get SQS queue URL:")
}
}

Expand Down
2 changes: 1 addition & 1 deletion pkg/target/kinesis_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ func TestKinesisTarget_WriteFailure(t *testing.T) {
writeRes, err := target.Write(messages)
assert.NotNil(err)
if err != nil {
assert.Equal("Error writing messages to Kinesis stream: 1 error occurred:\n\t* Failed to send message batch to Kinesis stream: ResourceNotFoundException: Stream not-exists under account 000000000000 not found.\n\n", err.Error())
assert.Contains(err.Error(), "Error writing messages to Kinesis stream: 1 error occurred:")
}
assert.NotNil(writeRes)

Expand Down

0 comments on commit be2dd83

Please sign in to comment.