import json

result = {}

try:
    pipeline_id = params_kw.get('pipeline_id', '')

    if not pipeline_id:
        result = {'status': 'error', 'error': 'missing pipeline_id'}
    else:
        import aioredis
        redis = await aioredis.from_url('redis://127.0.0.1:6379', db=1)
        data = await redis.get(f'pipeline:{pipeline_id}')
        await redis.close()

        if data:
            result = json.loads(data)
        else:
            result = {'status': 'error', 'error': f'pipeline {pipeline_id} not found'}

except Exception as e:
    result = {'status': 'error', 'error': str(e)}

return json.dumps(result, ensure_ascii=False)