|
|
@ -74,7 +74,8 @@ class AnalyticUnitManager: |
|
|
|
if task['type'] == 'PUSH': |
|
|
|
if task['type'] == 'PUSH': |
|
|
|
# TODO: do it a better way |
|
|
|
# TODO: do it a better way |
|
|
|
res = await worker.recieve_data(data, payload['cache']) |
|
|
|
res = await worker.recieve_data(data, payload['cache']) |
|
|
|
res.update({ 'analyticUnitId': analytic_unit_id }) |
|
|
|
if res: |
|
|
|
|
|
|
|
res.update({ 'analyticUnitId': analytic_unit_id }) |
|
|
|
return res |
|
|
|
return res |
|
|
|
elif task['type'] == 'LEARN': |
|
|
|
elif task['type'] == 'LEARN': |
|
|
|
if 'segments' in payload: |
|
|
|
if 'segments' in payload: |
|
|
|