Drop `NoData` handler, just let it bubble
							parent
							
								
									2b231ba631
								
							
						
					
					
						commit
						610fb5f7c6
					
				| 
						 | 
					@ -78,7 +78,6 @@ from ._sampling import (
 | 
				
			||||||
    _default_delay_s,
 | 
					    _default_delay_s,
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
from ..brokers._util import (
 | 
					from ..brokers._util import (
 | 
				
			||||||
    NoData,
 | 
					 | 
				
			||||||
    DataUnavailable,
 | 
					    DataUnavailable,
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					@ -369,15 +368,8 @@ async def start_backfill(
 | 
				
			||||||
                    end_dt=start_dt,
 | 
					                    end_dt=start_dt,
 | 
				
			||||||
                )
 | 
					                )
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            except NoData:
 | 
					            # broker says there never was or is no more history to pull
 | 
				
			||||||
                # XXX: unhandled history gap (shouldn't happen?)
 | 
					            except DataUnavailable:
 | 
				
			||||||
                log.warning(
 | 
					 | 
				
			||||||
                    f'NO DATA for {frame_size_s}s frame @ {start_dt} ?!?'
 | 
					 | 
				
			||||||
                )
 | 
					 | 
				
			||||||
                await tractor.breakpoint()
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
            except DataUnavailable:  # as duerr:
 | 
					 | 
				
			||||||
                # broker is being a bish and we can't pull any more..
 | 
					 | 
				
			||||||
                log.warning(
 | 
					                log.warning(
 | 
				
			||||||
                    f'NO-MORE-DATA: backend {mod.name} halted history!?'
 | 
					                    f'NO-MORE-DATA: backend {mod.name} halted history!?'
 | 
				
			||||||
                )
 | 
					                )
 | 
				
			||||||
| 
						 | 
					@ -644,7 +636,6 @@ async def tsdb_backfill(
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            while (
 | 
					            while (
 | 
				
			||||||
                shm._first.value > 0
 | 
					                shm._first.value > 0
 | 
				
			||||||
                # and frame_start < last_frame_start
 | 
					 | 
				
			||||||
            ):
 | 
					            ):
 | 
				
			||||||
                tsdb_history = await storage.read_ohlcv(
 | 
					                tsdb_history = await storage.read_ohlcv(
 | 
				
			||||||
                    fqsn,
 | 
					                    fqsn,
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue