Compare commits
	
		
			2 Commits 
		
	
	
		
			2a24d1d50c
			...
			3ff0a86741
		
	
	| Author | SHA1 | Date | 
|---|---|---|
| 
							
							
								 | 
						3ff0a86741 | |
| 
							
							
								 | 
						705f0e86ac | 
| 
						 | 
				
			
			@ -876,6 +876,7 @@ async def uniform_rate_send(
 | 
			
		|||
        except tractor.RemoteActorError as rme:
 | 
			
		||||
            if rme.type is not tractor._exceptions.StreamOverrun:
 | 
			
		||||
                raise
 | 
			
		||||
 | 
			
		||||
            ctx = stream._ctx
 | 
			
		||||
            chan = ctx.chan
 | 
			
		||||
            log.warning(
 | 
			
		||||
| 
						 | 
				
			
			@ -892,6 +893,7 @@ async def uniform_rate_send(
 | 
			
		|||
            trio.ClosedResourceError,
 | 
			
		||||
            trio.BrokenResourceError,
 | 
			
		||||
            ConnectionResetError,
 | 
			
		||||
            trio.EndOfChannel,
 | 
			
		||||
        ):
 | 
			
		||||
            # if the feed consumer goes down then drop
 | 
			
		||||
            # out of this rate limiter
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -62,8 +62,9 @@ ignore-init-module-imports = false
 | 
			
		|||
fixable = ["ALL"]
 | 
			
		||||
unfixable = []
 | 
			
		||||
 | 
			
		||||
# TODO? uhh why no work!?
 | 
			
		||||
# Allow unused variables when underscore-prefixed.
 | 
			
		||||
dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"
 | 
			
		||||
# dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"
 | 
			
		||||
 | 
			
		||||
[format]
 | 
			
		||||
# Use single quotes in `ruff format`.
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue