Commitd18e39f

Sergio García Prado

committed

* Improve timeout behaviour.

1 parent4f585c5 commitd18e39fCopy full SHA for d18e39f

File tree

-2

lines changed

-2

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -99,11 +99,14 @@ async def execute(self, operation: DatabaseOperation) -> None:`
`99`	`99`	`awaitself._create_lock(operation.lock)`
`100`	`100`
`101`	`101`	`ifisinstance(operation,ComposedDatabaseOperation):`
`102`		`-foropinoperation.operations:`
`103`		`-awaitwait_for(self.execute(op),operation.timeout)`
	`102`	`+awaitwait_for(self._execute_composed(operation),operation.timeout)`
`104`	`103`	`else:`
`105`	`104`	`awaitwait_for(self._execute(operation),operation.timeout)`
`106`	`105`
	`106`	`+asyncdef_execute_composed(self,operation:ComposedDatabaseOperation)->None:`
	`107`	`+foropinoperation.operations:`
	`108`	`+awaitself.execute(op)`
	`109`	`+`
`107`	`110`	`@abstractmethod`
`108`	`111`	`asyncdef_execute(self,operation:DatabaseOperation)->None:`
`109`	`112`	`raiseNotImplementedError`

Comments

(0)