Skip to content

Commit

Permalink
[SPARK-49927][SS][PYTHON][TESTS][FOLLOW-UP] Fixes `q.lastProgress.bat…
Browse files Browse the repository at this point in the history
…chId` to `q.lastProgress.progress.batchId`

### What changes were proposed in this pull request?

This PR is a followup of apache#48414 that fixes `q.lastProgress.batchId` -> `q.lastProgress.progress.batchId` to fix the test.

### Why are the changes needed?

`q.lastProgress` does not have `progress`. We should fix it to fix up the broken build.

### Does this PR introduce _any_ user-facing change?

No, test-only.

### How was this patch tested?

Manually

### Was this patch authored or co-authored using generative AI tooling?

No.

Closes apache#48419 from HyukjinKwon/SPARK-49927-followup.

Authored-by: Hyukjin Kwon <gurwls223@apache.org>
Signed-off-by: Hyukjin Kwon <gurwls223@apache.org>
  • Loading branch information
HyukjinKwon committed Oct 11, 2024
1 parent 4666972 commit cacd261
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ def onQueryTerminated(self, event):

q = observed_ds.writeStream.format("noop").start()

while q.lastProgress is None or q.lastProgress.batchId == 0:
while q.lastProgress is None or q.lastProgress.progress.batchId == 0:
q.awaitTermination(0.5)

time.sleep(5)
Expand Down

0 comments on commit cacd261

Please sign in to comment.