@@ -69,7 +69,7 @@ def insert(self, cn, newts, name, author,
69
69
isinstance (newts .index , pd .MultiIndex ))
70
70
71
71
newts .name = name
72
- tablename = self ._serie_to_tablename (cn , name )
72
+ tablename = self ._series_to_tablename (cn , name )
73
73
74
74
if tablename is None :
75
75
seriesmeta = self ._series_initial_meta (cn , name , newts )
@@ -168,7 +168,7 @@ def history(self, cn, name,
168
168
to_value_date = None ,
169
169
diffmode = False ,
170
170
_keep_nans = False ):
171
- tablename = self ._serie_to_tablename (cn , name )
171
+ tablename = self ._series_to_tablename (cn , name )
172
172
if tablename is None :
173
173
return
174
174
@@ -267,11 +267,11 @@ def staircase(self, cn, name, delta,
267
267
268
268
@tx
269
269
def exists (self , cn , name ):
270
- return self ._serie_to_tablename (cn , name ) is not None
270
+ return self ._series_to_tablename (cn , name ) is not None
271
271
272
272
@tx
273
273
def latest_insertion_date (self , cn , name ):
274
- tablename = self ._serie_to_tablename (cn , name )
274
+ tablename = self ._series_to_tablename (cn , name )
275
275
q = select ('max(insertion_date)' ).table (
276
276
f'"{ self .namespace } .revision"."{ tablename } "'
277
277
)
@@ -305,7 +305,7 @@ def changeset_at(self, cn, name, revdate, mode='strict'):
305
305
'before' : '<=' ,
306
306
'after' : '>='
307
307
}
308
- tablename = self ._serie_to_tablename (cn , name )
308
+ tablename = self ._series_to_tablename (cn , name )
309
309
assert mode in operators
310
310
q = select (
311
311
'id'
@@ -326,7 +326,7 @@ def rename(self, cn, oldname, newname):
326
326
327
327
@tx
328
328
def delete (self , cn , name ):
329
- tablename = self ._serie_to_tablename (cn , name )
329
+ tablename = self ._series_to_tablename (cn , name )
330
330
if tablename is None :
331
331
print ('not deleting unknown series' , name , self .namespace )
332
332
return
@@ -353,7 +353,7 @@ def delete(self, cn, name):
353
353
@tx
354
354
def strip (self , cn , name , csid ):
355
355
# wipe the diffs
356
- tablename = self ._serie_to_tablename (cn , name )
356
+ tablename = self ._series_to_tablename (cn , name )
357
357
sql = (f'delete from "{ self .namespace } .revision"."{ tablename } " '
358
358
'where id >= %(csid)s' )
359
359
cn .execute (sql , csid = csid )
@@ -394,7 +394,7 @@ def log(self, cn, name, limit=0, authors=None,
394
394
def _log_series_query (self , cn , name ,
395
395
authors = None ,
396
396
fromdate = None , todate = None ):
397
- tablename = self ._serie_to_tablename (cn , name )
397
+ tablename = self ._series_to_tablename (cn , name )
398
398
q = select (
399
399
'id' , 'author' , 'insertion_date' , 'metadata' ,
400
400
opt = 'distinct'
@@ -417,7 +417,7 @@ def _log_series_query(self, cn, name,
417
417
418
418
@tx
419
419
def interval (self , cn , name , notz = False ):
420
- tablename = self ._serie_to_tablename (cn , name )
420
+ tablename = self ._series_to_tablename (cn , name )
421
421
if tablename is None :
422
422
raise ValueError (f'no such serie: { name } ' )
423
423
sql = (f'select tsstart, tsend '
@@ -527,7 +527,7 @@ def _update(self, cn, tablename, newts, name, author,
527
527
528
528
def _new_revision (self , cn , name , head , tsstart , tsend ,
529
529
author , insertion_date , metadata ):
530
- tablename = self ._serie_to_tablename (cn , name )
530
+ tablename = self ._series_to_tablename (cn , name )
531
531
if insertion_date is not None :
532
532
assert insertion_date .tzinfo is not None
533
533
idate = pd .Timestamp (insertion_date )
@@ -570,7 +570,7 @@ def _make_tablename(self, cn, name):
570
570
cn .cache ['series_tablename' ][name ] = tablename
571
571
return tablename
572
572
573
- def _serie_to_tablename (self , cn , name ):
573
+ def _series_to_tablename (self , cn , name ):
574
574
tablename = cn .cache ['series_tablename' ].get (name )
575
575
if tablename is not None :
576
576
return tablename
@@ -610,7 +610,7 @@ def _register_serie(self, cn, name, seriesmeta):
610
610
'(seriesname, tablename, metadata) '
611
611
'values (%s, %s, %s) '
612
612
'returning id' )
613
- tablename = self ._serie_to_tablename (cn , name )
613
+ tablename = self ._series_to_tablename (cn , name )
614
614
regid = cn .execute (
615
615
sql ,
616
616
name ,
@@ -621,7 +621,7 @@ def _register_serie(self, cn, name, seriesmeta):
621
621
# changeset handling
622
622
623
623
def _previous_cset (self , cn , name , csid ):
624
- tablename = self ._serie_to_tablename (cn , name )
624
+ tablename = self ._series_to_tablename (cn , name )
625
625
sql = (f'select id from "{ self .namespace } .revision"."{ tablename } " '
626
626
'where id < %(csid)s '
627
627
'order by id desc limit 1' )
@@ -650,7 +650,7 @@ def _revisions(self, cn, name,
650
650
to_insertion_date = None ,
651
651
from_value_date = None ,
652
652
to_value_date = None ):
653
- tablename = self ._serie_to_tablename (cn , name )
653
+ tablename = self ._series_to_tablename (cn , name )
654
654
q = select (
655
655
'id' , 'insertion_date'
656
656
).table (
0 commit comments