@@ -1494,8 +1494,9 @@ def _UpdateRandom(self, subjects, fraction, change_test=True):
1494
1494
elif which == 1 :
1495
1495
# Add another timestamp.
1496
1496
timestamp_info .append (100 * number_timestamps + 1 )
1497
- data_store .DB .Set (subject , self .predicate_template % j , new_value ,
1498
- replace = False , timestamp = timestamp_info [- 1 ], token = self .token )
1497
+ data_store .DB .Set (
1498
+ subject , self .predicate_template % j , new_value ,
1499
+ replace = False , timestamp = timestamp_info [- 1 ], token = self .token )
1499
1500
self .values += 1
1500
1501
self .Register ()
1501
1502
elif which == 2 :
@@ -1600,8 +1601,9 @@ def _AddNewSubject(self, client, subjects, i, value, max_attributes=3):
1600
1601
ts = [100 * (ts + 1 ) for ts in xrange (number_timestamps )]
1601
1602
predicates [j ] = ts
1602
1603
values = [(value , t ) for t in ts ]
1603
- data_store .DB .MultiSet (subject , {self .predicate_template % j : values },
1604
- timestamp = 100 , replace = False , sync = False , token = self .token )
1604
+ data_store .DB .MultiSet (
1605
+ subject , {self .predicate_template % j : values },
1606
+ timestamp = 100 , replace = False , sync = False , token = self .token )
1605
1607
self .Register ()
1606
1608
info = {"name" : subject , "attrs" : predicates }
1607
1609
subjects [i ] = info
@@ -1635,8 +1637,9 @@ def _AddManyAttributes(self, subjects, many):
1635
1637
self .values += number_timestamps
1636
1638
values = [(new_value , t ) for t in ts ]
1637
1639
predicates [j ] = ts
1638
- data_store .DB .MultiSet (subject , {self .predicate_template % j : values },
1639
- replace = False , timestamp = 100 , sync = False , token = self .token )
1640
+ data_store .DB .MultiSet (
1641
+ subject , {self .predicate_template % j : values },
1642
+ replace = False , timestamp = 100 , sync = False , token = self .token )
1640
1643
self .Register ()
1641
1644
data_store .DB .Flush ()
1642
1645
0 commit comments