_logger.info("HEAD %s: %s bytes",
self._result['status_code'],
self._result.get('content-length'))
- return str(self._result.get('content-length'))
+ return True
_logger.info("GET %s: %s bytes in %s msec (%.3f MiB/sec)",
self._result['status_code'],
self.block_cache.cap_cache()
if loop.success():
if method == "HEAD":
- return "true"
+ return "True"
else:
return blob
locator,
'^b9a772c7049325feb7130fff1f8333e9\+9',
'wrong md5 hash from Keep.put for "test_head": ' + locator)
- self.assertEqual("true", self.keep_client.head(locator))
+ self.assertEqual("True", self.keep_client.head(locator))
self.assertEqual(self.keep_client.get(locator),
'test_head',
'wrong content from Keep.get for "test_head"')
self.assertEqual('foo', self.keepClient.get(locator))
self.assertEqual(self.gateway_roots[0]+locator,
MockCurl.return_value.getopt(pycurl.URL))
- self.assertEqual("true", self.keepClient.head(locator))
+ self.assertEqual("True", self.keepClient.head(locator))
@mock.patch('pycurl.Curl')
def test_get_with_gateway_hints_in_order(self, MockCurl):
code=200, body='foo', headers={'Content-Length': 3})
self.mock_disks_and_gateways()
locator = 'acbd18db4cc2f85cedef654fccc4a4d8+3+K@xyzzy'
- self.assertEqual("true", self.keepClient.head(locator))
+ self.assertEqual("True", self.keepClient.head(locator))
self.assertEqual('https://keep.xyzzy.arvadosapi.com/'+locator,
MockCurl.return_value.getopt(pycurl.URL))
@tutil.skip_sleep
class KeepClientRetryHeadTestCase(KeepClientRetryTestMixin, unittest.TestCase):
- DEFAULT_EXPECT = "true"
+ DEFAULT_EXPECT = "True"
DEFAULT_EXCEPTION = arvados.errors.KeepReadError
HINTED_LOCATOR = KeepClientRetryTestMixin.TEST_LOCATOR + '+K@xyzzy'
TEST_PATCHER = staticmethod(tutil.mock_keep_responses)