process_batch upon __serialize__

Author: hugetim

client_code/auto_batch.py

@@ -198,6 +198,13 @@ def __repr__(self):
     def __iter__(self):
         return iter(dict(self.row).items())
 
+    @if_not_deleted
+    def __serialize__(self, global_data):
+        if _add_queue or _update_queue or _delete_queue:
+            print("AutoBatch: process_batch triggered early by row __serialize__")
+        process_batch()
+        return self.__dict__
+    
     @property
     def cache(self):
         return self._cache
@@ -219,6 +226,12 @@ def __getitem__(self, index):
     def __len__(self):
         return len(self._search_iterator)
 
+    def __serialize__(self, global_data):
+        if _add_queue or _update_queue or _delete_queue:
+            print("AutoBatch: process_batch triggered early by search iterator __serialize__")
+        process_batch()
+        return self.__dict__
+
 
 @portable_class
 class BatchTable(anvil.tables.Table):
@@ -283,6 +296,12 @@ def get_batch_row(self, row):
 
     def retrieve_batch_row(self, row):
         return self._batch_rows[row.get_id()]
+
+    def __serialize__(self, global_data):
+        if _add_queue or _update_queue or _delete_queue:
+            print("AutoBatch: process_batch triggered early by table __serialize__")
+        process_batch()
+        return self.__dict__
 
     def clear_cache(self):
         for batch_row in self._batch_rows.values():
@@ -294,7 +313,6 @@ def of_row(row):
         return get_table_by_id(row._table_id)
 
 
-@portable_class
 class BatchTables:
     def __init__(self):
         self._name_list = list(anvil.tables.app_tables)