Skip to content

Commit

Permalink
Add log line
Browse files Browse the repository at this point in the history
  • Loading branch information
obulat committed Mar 28, 2023
1 parent f345e6f commit 4ac1fe6
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion ingestion_server/test/integration_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,8 +253,12 @@ def _ingest_upstream(self, model, suffix="integration"):
stat_msg = "The job should launch successfully and return 202 ACCEPTED."
self.assertEqual(res.status_code, 202, msg=stat_msg)

logging.info(
f"Waiting for the task to send us a callback {self.__class__.cb_queue}"
)

# Wait for the task to send us a callback.
assert self.__class__.cb_queue.get(timeout=120) == "CALLBACK!"
assert self.__class__.cb_queue.get(timeout=240) == "CALLBACK!"

# Check that the indices remained the same
after_indices = self._get_indices(self.downstream_db, model)
Expand Down

0 comments on commit 4ac1fe6

Please sign in to comment.