... | ... | @@ -111,3 +111,25 @@ $$, estimate_conf) |
|
|
|
|
|
run_parallel(_sql=sql, _processes=3, _verbose=False)
|
|
|
```
|
|
|
|
|
|
or more simply use fn_make_estimate(...)
|
|
|
|
|
|
```py
|
|
|
#!/usr/bin/env python3
|
|
|
# -*- coding: utf-8 -*-
|
|
|
import sys
|
|
|
sys.path.append('./')
|
|
|
from nfiesta_parallel import run_parallel
|
|
|
|
|
|
sql = '''select format($$
|
|
|
select estimate_conf from nfiesta_test.fn_make_estimate(%s)
|
|
|
;
|
|
|
$$, estimate_conf)
|
|
|
FROM ( SELECT estimate_conf
|
|
|
FROM nfiesta_test.v_conf_overview
|
|
|
WHERE estimate_type_str = '2p_total'
|
|
|
) AS estimates_to_compute
|
|
|
;'''
|
|
|
|
|
|
run_parallel(_sql=sql, _processes=12, _verbose=True)
|
|
|
``` |
|
|
\ No newline at end of file |