Fix errors when deleting mapper data (#3018)

Author: hekaisheng

mars/services/lifecycle/supervisor/tracker.py

@@ -86,10 +86,6 @@ def _incref_chunks(self, chunk_keys: List[str], counts: List[int] = None):
             self._chunk_ref_counts[chunk_key] += count
 
     async def incref_chunks(self, chunk_keys: List[str], counts: List[int] = None):
-        logger.debug(
-            "Increase reference count for chunks %s",
-            {ck: self._chunk_ref_counts[ck] for ck in chunk_keys},
-        )
         self._check_ref_counts(chunk_keys, counts)
         return await asyncio.to_thread(self._incref_chunks, chunk_keys, counts=counts)
 
@@ -108,10 +104,6 @@ def _get_remove_chunk_keys(self, chunk_keys: List[str], counts: List[int] = None
 
     async def decref_chunks(self, chunk_keys: List[str], counts: List[int] = None):
         self._check_ref_counts(chunk_keys, counts)
-        logger.debug(
-            "Decrease reference count for chunks %s",
-            {ck: self._chunk_ref_counts[ck] for ck in chunk_keys},
-        )
         to_remove_chunk_keys = await asyncio.to_thread(
             self._get_remove_chunk_keys, chunk_keys, counts=counts
         )

mars/services/storage/api/oscar.py

@@ -189,7 +189,7 @@ async def fetch(
             self._session_id, [data_key], level, band_name, remote_address, error
         )
         if fetch_key:
-            return fetch_key
+            return fetch_key[0]
 
     @fetch.batch
     async def batch_fetch(self, args_list, kwargs_list):