code: async def _on_progress_notification(self, progress):
          
  
          conn_string = progress.get('connection_string')
          done = progress.get('done_count')
          total = progress.get('total_count')
          operation = progress.get('operation')
  
          await self.notify_progress(conn_string, operation, done, total, wait=True)
docs: Callback function called when a progress notification is received.
  
          Args:
              progress (dict): The received notification containing the progress information