15 lines
539 B
Plaintext
15 lines
539 B
Plaintext
tenant_id = (await get_userorgid()) or '0'
|
|
pipeline_id = params_kw.get('pipeline_id', None)
|
|
limit = int(params_kw.get('limit', 100))
|
|
|
|
try:
|
|
result = await pipeline_list(tenant_id, pipeline_id, limit)
|
|
# DataViewer期望rows键
|
|
data = json.loads(result)
|
|
if data.get('success') and 'tasks' in data:
|
|
data['rows'] = data.pop('tasks')
|
|
return json.dumps(data, ensure_ascii=False, default=str)
|
|
return result
|
|
except Exception as e:
|
|
return json.dumps({"success": False, "message": str(e)}, ensure_ascii=False)
|