Skip to content

Commit e9908ed

Browse files
committed
Override hive lock waiting logic to immediately fail
1 parent a34aeef commit e9908ed

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

pyiceberg/catalog/hive.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -518,10 +518,7 @@ def commit_table(
518518
lock: LockResponse = open_client.lock(self._create_lock_request(database_name, table_name))
519519
try:
520520
if lock.state != LockState.ACQUIRED:
521-
if lock.state == LockState.WAITING:
522-
self._wait_for_lock(database_name, table_name, lock.lockid, open_client)
523-
else:
524-
raise CommitFailedException(f"Failed to acquire lock for {table_identifier}, lock state: {lock.state}")
521+
raise CommitFailedException(f"Failed to acquire lock for {table_identifier}, lock state: {lock.state}")
525522
else:
526523
logger.debug("Acquired lock on initial attempt.")
527524

0 commit comments

Comments
 (0)