Skip to content

Commit

Permalink
Ingester: cleanup tests.
Browse files Browse the repository at this point in the history
  • Loading branch information
ABPLMC committed Oct 4, 2024
1 parent 08830c8 commit a2e1630
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions ingester/tests/test_storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,18 +40,15 @@ def test_insert_new_record(dynamodb_latest_table, dynamodb_connection):
'create_time': 1500000000000
}

try:
storage.store_latest(new_record)
except Exception as e:
print(f"Failed to store record: {str(e)}")
storage.store_latest(new_record)

stored_record = dynamodb_latest_table.get_item(
what_where_key=new_record['what_where_key']
)
assert stored_record['metadata']['start'] == new_record['metadata']['start']


def test_insert_duplicate_writes_once(dynamodb_latest_table, dynamodb_connection):
def test_store_conditional_put_latest_multiple_files(dynamodb_latest_table, dynamodb_connection):
storage = DynamoDBStorage(connection=dynamodb_connection)
storage.latest_table_name = 'latest'

Expand Down Expand Up @@ -144,8 +141,7 @@ def test_insert_duplicate_writes_once(dynamodb_latest_table, dynamodb_connection
assert res['metadata']['start'] == file2['metadata']['start']



def test_verify_replace_same_start_time(dynamodb_latest_table, dynamodb_connection):
def test_verify_replace_record_same_start(dynamodb_latest_table, dynamodb_connection):
storage = DynamoDBStorage(connection=dynamodb_connection)
storage.latest_table_name = 'latest'

Expand Down

0 comments on commit a2e1630

Please sign in to comment.