我正在使用postgres数据库运行airlfow本地执行程序,我得到一个:(psycopg2.OperationalError)致命:保留剩余的连接槽
我的配置:
sql_alchemy_pool_size = 5…
您将主进程的分支作为worker,每个都管理自己的线程池。
检查执行情况 LocalExecutor ;因为它在引擎盖下使用多处理。 SqlAlchemy将在分叉时关闭所有打开的连接 LocalWorker ;但是池的大小将等同于父级,所以在最大程度上,理论上你会有 k * (n + 1) 连接,在哪里 n 你的并行性是不变的 k 是你的 sql_alchemy_pool_size 。
LocalWorker
k * (n + 1)
n
k
sql_alchemy_pool_size