@@ -19,6 +19,7 @@ def run(site, product):
def handle(data):
task = []
+ product = Demeter.service('product')
for v in data:
product.status(v['id'], 2)
site = product.getSite(v['site_id'])