diff --git a/.github/workflows/dynamodb.yml b/.github/workflows/dynamodb.yml index d01b2225..00081e3a 100644 --- a/.github/workflows/dynamodb.yml +++ b/.github/workflows/dynamodb.yml @@ -7,12 +7,14 @@ on: paths: - '.github/workflows/dynamodb.yml' - 'cratedb_toolkit/io/dynamodb/**' + - 'tests/io/dynamodb/**' - 'pyproject.toml' push: branches: [ main ] paths: - '.github/workflows/dynamodb.yml' - 'cratedb_toolkit/io/dynamodb/**' + - 'tests/io/dynamodb/**' - 'pyproject.toml' # Allow job to be triggered manually. diff --git a/tests/io/dynamodb/test_copy.py b/tests/io/dynamodb/test_copy.py index b758d59a..8d1d605e 100644 --- a/tests/io/dynamodb/test_copy.py +++ b/tests/io/dynamodb/test_copy.py @@ -1,5 +1,10 @@ +import pytest + from cratedb_toolkit.io.dynamodb.copy import DynamoDBFullLoad +pytestmark = pytest.mark.dynamodb + + RECORD_UTM = { "Id": {"N": "101"}, "utmTags": { @@ -15,10 +20,17 @@ } ] }, + "location": { + "M": { + "coordinates": {"L": [{"S": ""}]}, + "meetingPoint": {"S": "At the end of the tunnel"}, + "address": {"S": "Salzbergwerk Berchtesgaden"}, + }, + }, } -def test_dynamodb_copy_list_of_objects(caplog, cratedb, dynamodb, dynamodb_test_manager): +def test_dynamodb_copy(caplog, cratedb, dynamodb, dynamodb_test_manager): """ CLI test: Invoke `ctk load table` for DynamoDB. """ @@ -51,4 +63,9 @@ def test_dynamodb_copy_list_of_objects(caplog, cratedb, dynamodb, dynamodb_test_ "utm_source": "google", } ], + "location": { + "coordinates": [""], + "meetingPoint": "At the end of the tunnel", + "address": "Salzbergwerk Berchtesgaden", + }, }