25 lines
646 B
Plaintext
25 lines
646 B
Plaintext
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)
|