diff --git a/python_modules/dagster/dagster_tests/storage_tests/utils/run_storage.py b/python_modules/dagster/dagster_tests/storage_tests/utils/run_storage.py index 7bf13c08054f3..fe90e70b4de24 100644 --- a/python_modules/dagster/dagster_tests/storage_tests/utils/run_storage.py +++ b/python_modules/dagster/dagster_tests/storage_tests/utils/run_storage.py @@ -4,6 +4,7 @@ import unittest from datetime import datetime, timedelta from typing import Optional +from uuid import uuid4 import pytest from dagster import _seven, job, op @@ -1094,7 +1095,7 @@ def test_add_get_snapshot(self, storage): assert not storage.has_job_snapshot(job_snapshot_id) def test_single_write_read_with_snapshot(self, storage: RunStorage): - run_with_snapshot_id = "lkasjdflkjasdf" + run_with_snapshot_id = str(uuid4()) job_def = GraphDefinition(name="some_pipeline", node_defs=[]).to_job() job_snapshot = job_def.get_job_snapshot()