add logging for get_groups
This commit is contained in:
parent
001f030fff
commit
d23a0abca2
1 changed files with 6 additions and 3 deletions
|
@ -38,7 +38,7 @@ class Location(NamedTuple):
|
||||||
alt: Optional[float]
|
alt: Optional[float]
|
||||||
tag: Tag
|
tag: Tag
|
||||||
|
|
||||||
dbcache = make_dbcache(CACHE_PATH, hashf=mtime_hash, type_=Location, chunk_by=10000)
|
dbcache = make_dbcache(CACHE_PATH, hashf=mtime_hash, type_=Location, chunk_by=10000, logger=get_logger())
|
||||||
|
|
||||||
|
|
||||||
def tagger(dt: datetime, point: geopy.Point) -> Tag:
|
def tagger(dt: datetime, point: geopy.Point) -> Tag:
|
||||||
|
@ -153,6 +153,8 @@ class Window:
|
||||||
|
|
||||||
# TODO maybe if tag is none, we just don't care?
|
# TODO maybe if tag is none, we just don't care?
|
||||||
def get_groups() -> List[LocInterval]:
|
def get_groups() -> List[LocInterval]:
|
||||||
|
logger = get_logger()
|
||||||
|
|
||||||
all_locations = iter(iter_locations()) # TODO
|
all_locations = iter(iter_locations()) # TODO
|
||||||
locsi = Window(all_locations)
|
locsi = Window(all_locations)
|
||||||
i = 0
|
i = 0
|
||||||
|
@ -174,8 +176,9 @@ def get_groups() -> List[LocInterval]:
|
||||||
curg = []
|
curg = []
|
||||||
|
|
||||||
while locsi.exists(i):
|
while locsi.exists(i):
|
||||||
# if i % 1000 == 0:
|
if i % 10000 == 0:
|
||||||
# print("processing " + str(i))
|
logger.debug('grouping item %d', i)
|
||||||
|
|
||||||
locsi.consume_to(i)
|
locsi.consume_to(i)
|
||||||
|
|
||||||
last = None if len(curg) == 0 else curg[-1]
|
last = None if len(curg) == 0 else curg[-1]
|
||||||
|
|
Loading…
Add table
Reference in a new issue