Python2 compatibility in tests

2015-10-11 23:59:26 +02:00
parent 22943e7e47
commit 7729c3048f
1 changed files with 1 additions and 1 deletions
@@ -18,7 +18,7 @@ class TestParallelBulk(TestCase):
    @mock.patch(
        'elasticsearch.helpers._process_bulk_chunk',
        # make sure we spend some time in the thread
-        side_effect=lambda *a: [(True, time.sleep(.001) or threading.get_ident())]
+        side_effect=lambda *a: [(True, time.sleep(.001) or threading.current_thread().ident)]
    )
    def test_chunk_sent_from_different_threads(self, _process_bulk_chunk):
        actions = ({'x': i} for i in range(100))