Removed filtering from low level object listing

gcsfs/core.py

@@ -496,7 +496,7 @@ def _filter_ghost_items(items):
         for item in items:
             if (
                 item.get("kind", "") == "storage#object"
-                and item.get("size", "") == "0"
+                and (item.get("size", "") == "0" or item.get("size", "") == 0)
                 and item.get("crc32c", "") == "AAAAAA=="
             ):
                 # This is a ghost item, skip it
@@ -599,7 +599,7 @@ async def _list_objects(self, path, prefix="", versions=False, **kwargs):
                 return [await self._get_object(path)]
             else:
                 return []
-        out = pseudodirs + items
+        out = pseudodirs + self._filter_ghost_items(items)
 
         use_snapshot_listing = inventory_report_info and inventory_report_info.get(
             "use_snapshot_listing"
@@ -765,7 +765,7 @@ async def _sequential_list_objects_helper(
         )
 
         prefixes.extend(page.get("prefixes", []))
-        items.extend(self._filter_ghost_items(page.get("items", [])))
+        items.extend(page.get("items", []))
         next_page_token = page.get("nextPageToken", None)
 
         while next_page_token is not None:
@@ -785,7 +785,7 @@ async def _sequential_list_objects_helper(
 
             assert page["kind"] == "storage#objects"
             prefixes.extend(page.get("prefixes", []))
-            items.extend(self._filter_ghost_items(page.get("items", [])))
+            items.extend(page.get("items", []))
             next_page_token = page.get("nextPageToken", None)
 
         items = [self._process_object(bucket, i) for i in items]
@@ -1421,6 +1421,10 @@ async def _find(
                 bucket, delimiter="", prefix=_prefix, versions=versions
             )
 
+        # Now filter the objects to remove the "ghost" ones. This cannot be done at "_do_list_objects" level,
+        # since there's some logic, reliant on presence of the "ghost" objects
+        objects = self._filter_ghost_items(objects)
+
         dirs = {}
         cache_entries = {}