19 lines
594 B
Plaintext
19 lines
594 B
Plaintext
try:
|
|
async with get_sor_context(request._run_ns, 'pipeline') as sor:
|
|
sql = '''
|
|
SELECT id, name, pipeline_type, status
|
|
FROM pipelines
|
|
WHERE status = 'published'
|
|
ORDER BY name
|
|
'''
|
|
recs = await sor.sqlExe(sql, {})
|
|
rows = []
|
|
for r in recs:
|
|
rows.append({
|
|
'value': r.id,
|
|
'text': '{} [{}]'.format(r.name, r.pipeline_type or ''),
|
|
})
|
|
return json.dumps(rows, ensure_ascii=False)
|
|
except Exception as e:
|
|
return json.dumps([], ensure_ascii=False)
|