12 lines
352 B
Plaintext
12 lines
352 B
Plaintext
from sqlor.dbpools import DBPools
|
|
|
|
async def main():
|
|
dbname = get_module_dbname('pipeline_core')
|
|
async with DBPools().sqlorContext(dbname) as sor:
|
|
recs = await sor.R('pipelines', {'status': 'published'})
|
|
if not recs:
|
|
recs = await sor.R('pipelines', {})
|
|
if not recs:
|
|
recs = []
|
|
return recs
|