extend test, fix bug

Author: janbuchar

src/apify/storage_clients/_file_system/_key_value_store_client.py

@@ -30,10 +30,7 @@ async def purge(self) -> None:
 
         # First try to find the alternative format of the input file and process it if it exists.
         for file_path in self.path_to_kvs.glob('*'):
-            if (
-                file_path.name in configuration.input_key_candidates
-                and file_path.name != configuration.canonical_input_key
-            ):
+            if file_path.name in configuration.input_key_candidates:
                 await self._process_input_json(file_path)
 
         async with self._lock:

tests/unit/storage_clients/test_file_system.py

@@ -4,6 +4,8 @@
 import json
 from typing import TYPE_CHECKING
 
+import pytest
+
 from crawlee._consts import METADATA_FILENAME
 
 from apify import Actor, Configuration
@@ -64,16 +66,16 @@ async def test_purge_preserves_input_file_and_metadata() -> None:
     assert input_content == '{"test": "input"}'
 
 
-async def test_pre_existing_input_used_by_actor(tmp_path: Path) -> None:
+@pytest.mark.parametrize('input_file_name', ['INPUT', 'INPUT.json'])
+async def test_pre_existing_input_used_by_actor(tmp_path: Path, input_file_name: str) -> None:
     pre_existing_input = {
         'foo': 'bar',
     }
 
-    configuration = Configuration.get_global_configuration()
     # Create pre-existing INPUT.json file
     path_to_input = tmp_path / 'key_value_stores' / 'default'
     path_to_input.mkdir(parents=True)
-    (path_to_input / f'{configuration.input_key}.json').write_text(json.dumps(pre_existing_input))
+    (path_to_input / input_file_name).write_text(json.dumps(pre_existing_input))
 
     async with Actor():
         assert pre_existing_input == await Actor.get_input()