|
@@ -114,15 +114,10 @@ class ItemBuffer(threading.Thread):
|
|
|
def put_item(self, item):
|
|
|
if isinstance(item, Item):
|
|
|
# 入库前的回调
|
|
|
-
|
|
|
- if item.item_name == "ListItem":
|
|
|
- return
|
|
|
item.pre_to_db()
|
|
|
- # print(item)
|
|
|
- if item.save:
|
|
|
- self._items_queue.put(item)
|
|
|
- else:
|
|
|
- self._items_queue.put(item)
|
|
|
+
|
|
|
+ self._items_queue.put(item)
|
|
|
+
|
|
|
def flush(self):
|
|
|
try:
|
|
|
items = []
|