let's see if it fails now

Author: john-z-yang

python/integration_tests/test_consumer_rebalancing.py

@@ -239,9 +239,8 @@ def test_tasks_written_once_during_rebalancing() -> None:
     print(f"Cleaning up test output files in {TESTS_OUTPUT_PATH}")
     shutil.rmtree(TESTS_OUTPUT_PATH)
 
-    if (
+    assert (
         not all([row[3] == 0 for row in row_count])
         or not consumers_have_data
         or consumers_have_error
-    ):
-        assert False
+    )

src/consumer/kafka.rs

@@ -172,7 +172,7 @@ pub struct ActorHandles {
 impl ActorHandles {
     #[instrument(skip(self))]
     async fn shutdown(mut self, deadline: Duration) {
-        debug!("Signaling shutdown to actors...");
+        error!("Signaling shutdown to actors...");
         self.shutdown.cancel();
         info!("Actor shutdown signaled, waiting for rendezvous...");