fix tests for changed error msg

lbryio · Oct 12, 2022 · 7291902 · 7291902
1 parent 7d01f16
commit 7291902
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/tests/integration/datanetwork/test_file_commands.py b/tests/integration/datanetwork/test_file_commands.py
@@ -354,12 +354,12 @@ async def test_download_different_timeouts(self):
  await self.server.blob_manager.delete_blobs(all_except_sd)
  resp = await self.daemon.jsonrpc_get('lbry://foo', timeout=2, save_file=True)
  self.assertIn('error', resp)
- self.assertEqual('Failed to download data blobs for sd hash %s within timeout.' % sd_hash, resp['error'])
+ self.assertEqual('Failed to download data blobs for %s within timeout.' % sd_hash, resp['error'])
  self.assertTrue(await self.daemon.jsonrpc_file_delete(claim_name='foo'), "data timeout didn't create a file")
  await self.server.blob_manager.delete_blobs([sd_hash])
  resp = await self.daemon.jsonrpc_get('lbry://foo', timeout=2, save_file=True)
  self.assertIn('error', resp)
- self.assertEqual('Failed to download sd blob %s within timeout.' % sd_hash, resp['error'])
+ self.assertEqual('Failed to download metadata for %s within timeout.' % sd_hash, resp['error'])
 
  async def wait_files_to_complete(self):
  while await self.file_list(status='running'):

diff --git a/tests/unit/stream/test_stream_manager.py b/tests/unit/stream/test_stream_manager.py
@@ -229,7 +229,7 @@ def check_post(event):
  self.assertFalse(event['properties']['added_fixed_peers'])
  self.assertEqual(event['properties']['connection_failures_count'], 1)
  self.assertEqual(
- event['properties']['error_message'], f'Failed to download sd blob {self.sd_hash} within timeout.'
+ event['properties']['error_message'], f'Failed to download metadata for {self.sd_hash} within timeout.'
  )
 
  await self._test_time_to_first_bytes(check_post, DownloadMetadataTimeoutError, after_setup=after_setup)
@@ -273,7 +273,7 @@ def check_post(event):
  self.assertFalse(event['properties']['added_fixed_peers'])
  self.assertIsNone(event['properties']['fixed_peer_delay'])
  self.assertEqual(
- event['properties']['error_message'], f'Failed to download sd blob {self.sd_hash} within timeout.'
+ event['properties']['error_message'], f'Failed to download metadata for {self.sd_hash} within timeout.'
  )
 
  start = self.loop.time()
@@ -387,7 +387,7 @@ async def test_download_sd_timeout(self):
  self.server.stop_server()
  await self.setup_stream_manager()
  await self._test_download_error_analytics_on_start(
- DownloadMetadataTimeoutError, f'Failed to download sd blob {self.sd_hash} within timeout.', timeout=1
+ DownloadMetadataTimeoutError, f'Failed to download metadata for {self.sd_hash} within timeout.', timeout=1
  )
 
  async def test_download_data_timeout(self):
@@ -396,7 +396,7 @@ async def test_download_data_timeout(self):
  head_blob_hash = json.loads(sdf.read())['blobs'][0]['blob_hash']
  self.server_blob_manager.delete_blob(head_blob_hash)
  await self._test_download_error_analytics_on_start(
- DownloadDataTimeoutError, f'Failed to download data blobs for sd hash {self.sd_hash} within timeout.', timeout=1
+ DownloadDataTimeoutError, f'Failed to download data blobs for {self.sd_hash} within timeout.', timeout=1
  )
 
  async def test_unexpected_error(self):