Write to temp S3 dir

Author: mkaruza

tests/dragonfly/snapshot_test.py

@@ -379,8 +379,8 @@ async def test_s3_snapshot(async_client, tmp_dir):
     "DRAGONFLY_S3_BUCKET" not in os.environ or os.environ["DRAGONFLY_S3_BUCKET"] == "",
     reason="AWS S3 snapshots bucket is not configured",
 )
-@dfly_args({**BASIC_ARGS, "vmodule": "s3_write_file=2,http_client=1"})
-async def test_s3_save_local_dir(async_client):
+@dfly_args({**BASIC_ARGS})
+async def test_s3_save_local_dir(async_client, tmp_dir):
     seeder = StaticSeeder(key_target=10_000)
     await seeder.run(async_client)
 
@@ -389,7 +389,7 @@ async def test_s3_save_local_dir(async_client):
     try:
         # SAVE to S3 bucket with `s3_dump` as filename prefix
         v = await async_client.execute_command(
-            "SAVE", "DF", "s3://" + os.environ["DRAGONFLY_S3_BUCKET"], "s3_dump"
+            "SAVE", "DF", "s3://" + os.environ["DRAGONFLY_S3_BUCKET"] + str(tmp_dir), "s3_dump"
         )
         logger = logging.getLogger(__name__)
         logger.debug(v)
@@ -398,7 +398,7 @@ async def test_s3_save_local_dir(async_client):
         list_s3_objects(os.environ["DRAGONFLY_S3_BUCKET"])
         delete_s3_objects(
             os.environ["DRAGONFLY_S3_BUCKET"],
-            "s3_dump",
+            str(tmp_dir)[1:] + "/s3_dump",
         )