Fix ty ignores

Author: vdusek

tests/integration/conftest.py

@@ -95,7 +95,7 @@ async def maybe_await(value: T | Coroutine[Any, Any, T]) -> T:
         result = await maybe_await(client.datasets().list())
     """
     if hasattr(value, '__await__'):
-        return await value  # type: ignore[misc,return-value]
+        return await value  # ty: ignore[invalid-await]
     return value
 
 

tests/integration/test_key_value_store.py

@@ -186,27 +186,34 @@ async def test_stream_record_signature(
     # We'll test the error condition separately based on client type
     try:
         if is_async:
-            async with kvs.stream_record(key=key) as stream:  # type: ignore[union-attr]
+            async with kvs.stream_record(key=key) as stream:  # ty: ignore[invalid-context-manager]
                 pass
             pytest.fail('Expected ApifyApiError')
         else:
-            with kvs.stream_record(key=key) as stream:  # type: ignore[union-attr]
+            with kvs.stream_record(key=key) as stream:  # ty: ignore[invalid-context-manager]
                 pass
             pytest.fail('Expected ApifyApiError')
     except ApifyApiError:
         pass  # Expected
 
     # Kvs content retrieved with correct signature
     if is_async:
-        async with kvs.stream_record(key=key, signature=test_kvs_of_another_user.keys_signature[key]) as stream:  # type: ignore[union-attr]
+        async with kvs.stream_record(
+            key=key,
+            signature=test_kvs_of_another_user.keys_signature[key],
+        ) as stream:  # ty: ignore[invalid-context-manager]
             assert stream
             stream_dict = cast('dict', stream)
             value = json.loads(stream_dict['value'].content.decode('utf-8'))
     else:
-        with kvs.stream_record(key=key, signature=test_kvs_of_another_user.keys_signature[key]) as stream:  # type: ignore[union-attr]
+        with kvs.stream_record(
+            key=key,
+            signature=test_kvs_of_another_user.keys_signature[key],
+        ) as stream:  # ty: ignore[invalid-context-manager]
             assert stream
             stream_dict = cast('dict', stream)
             value = json.loads(stream_dict['value'].content.decode('utf-8'))
+
     assert test_kvs_of_another_user.expected_content[key] == value