@@ -46,7 +46,7 @@ def expression_to_condition(expr, keys: set):
4646 if isinstance (expr , ast .NullExpression ):
4747 return None , set ()
4848 if isinstance (expr , ast .DatetimeExpression ):
49- return _to_epoch_float (expr .value ), set ()
49+ return _to_epoch_decimal (expr .value ), set ()
5050 if isinstance (expr , ast .StringExpression ):
5151 return expr .value , set ()
5252 if isinstance (expr , ast .FloatExpression ):
@@ -102,7 +102,7 @@ def _to_epoch_decimal(dt: datetime) -> Decimal:
102102
103103def chunk_list (lst , size ):
104104 for i in range (0 , len (lst ), size ):
105- yield lst [i : i + size ]
105+ yield lst [i : i + size ]
106106
107107
108108def index_definition (index_name , keys , gsi = False ):
@@ -438,7 +438,9 @@ def batch_save(self, items: list) -> dict:
438438 # chunk list for size limit of 25 items to write using this batch_write operation refer below.
439439 # https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb/client/batch_write_item.html#:~:text=The%20BatchWriteItem%20operation,Data%20Types.
440440 for chunk in chunk_list (items , 25 ):
441- serialized_items = [self .serializer .serialize_record (item .dict (by_alias = True )) for item in chunk ]
441+ serialized_items = [
442+ self .serializer .serialize_record (item .dict (by_alias = True )) for item in chunk
443+ ]
442444 for serialized_item in serialized_items :
443445 request_items [self .table_name ].append ({"PutRequest" : {"Item" : serialized_item }})
444446 try :
0 commit comments