diff --git a/test/worker.py b/test/worker.py
index <HASH>..<HASH> 100755
--- a/test/worker.py
+++ b/test/worker.py
@@ -496,9 +496,9 @@ class TestBaseSplitCloneResiliency(TestBaseSplitClone):
       # for each destination shard ("finding targets" state).
       utils.poll_for_vars(
           'vtworker', worker_port,
-          'WorkerState == cloning the data (offline)',
+          'WorkerState == cloning the data (online)',
           condition_fn=lambda v: v.get('WorkerState') == 'cloning the'
-          ' data (offline)')
+          ' data (online)')
       logging.debug('Worker is in copy state, starting reparent now')
 
       utils.run_vtctl(
test: worker.py: Wait for online instead of the offline phase to run the reparent.