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)