Datahub error log 2

~~~~ Execution Summary ~~~~

RUN_INGEST - {'errors': [],
 'exec_id': 'c8714baa-5356-494b-8268-4b3c987419b2',
 'infos': ['2022-06-20 14:10:01.147426 [exec_id=c8714baa-5356-494b-8268-4b3c987419b2] INFO: Starting execution for task with name=RUN_INGEST',
           '2022-06-20 14:11:27.120876 [exec_id=c8714baa-5356-494b-8268-4b3c987419b2] INFO: stdout=Requirement already satisfied: pip in '
           '/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages (21.2.4)\n'
           'Collecting pip\n'
           '  Using cached pip-22.1.2-py3-none-any.whl (2.1 MB)\n'
           'Collecting wheel\n'
           '  Using cached wheel-0.37.1-py2.py3-none-any.whl (35 kB)\n'
           'Requirement already satisfied: setuptools in /tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages '
           '(58.1.0)\n'
           'Collecting setuptools\n'
           '  Using cached setuptools-62.6.0-py3-none-any.whl (1.2 MB)\n'
           'Installing collected packages: wheel, setuptools, pip\n'
           '  Attempting uninstall: setuptools\n'
           '    Found existing installation: setuptools 58.1.0\n'
           '    Uninstalling setuptools-58.1.0:\n'
           '      Successfully uninstalled setuptools-58.1.0\n'
           '  Attempting uninstall: pip\n'
           '    Found existing installation: pip 21.2.4\n'
           '    Uninstalling pip-21.2.4:\n'
           '      Successfully uninstalled pip-21.2.4\n'
           'Successfully installed pip-22.1.2 setuptools-62.6.0 wheel-0.37.1\n'
           'Collecting acryl-datahub[datahub-rest,postgres]==0.8.38\n'
           '  Using cached acryl_datahub-0.8.38-py3-none-any.whl (877 kB)\n'
           'Collecting entrypoints\n'
           '  Using cached entrypoints-0.4-py3-none-any.whl (5.3 kB)\n'
           'Collecting avro-gen3==0.7.4\n'
           '  Using cached avro_gen3-0.7.4-py3-none-any.whl (26 kB)\n'
           'Collecting typing-extensions>=3.10.0.2\n'
           '  Using cached typing_extensions-4.2.0-py3-none-any.whl (24 kB)\n'
           'Collecting Deprecated\n'
           '  Using cached Deprecated-1.2.13-py2.py3-none-any.whl (9.6 kB)\n'
           'Collecting avro<1.11,>=1.10.2\n'
           '  Using cached avro-1.10.2-py3-none-any.whl\n'
           'Collecting tabulate\n'
           '  Using cached tabulate-0.8.9-py3-none-any.whl (25 kB)\n'
           'Collecting psutil>=5.8.0\n'
           '  Using cached psutil-5.9.1-cp39-cp39-manylinux_2_12_x86_64.manylinux2010_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl (281 '
           'kB)\n'
           'Collecting ratelimiter\n'
           '  Using cached ratelimiter-1.2.0.post0-py3-none-any.whl (6.6 kB)\n'
           'Collecting humanfriendly\n'
           '  Using cached humanfriendly-10.0-py2.py3-none-any.whl (86 kB)\n'
           'Collecting expandvars>=0.6.5\n'
           '  Using cached expandvars-0.9.0-py3-none-any.whl (6.6 kB)\n'
           'Collecting mypy-extensions>=0.4.3\n'
           '  Using cached mypy_extensions-0.4.3-py2.py3-none-any.whl (4.5 kB)\n'
           'Collecting typing-inspect\n'
           '  Using cached typing_inspect-0.7.1-py3-none-any.whl (8.4 kB)\n'
           'Collecting types-termcolor>=1.0.0\n'
           '  Using cached types_termcolor-1.1.4-py3-none-any.whl (2.1 kB)\n'
           'Collecting click-default-group\n'
           '  Using cached click_default_group-1.2.2-py3-none-any.whl\n'
           'Collecting docker\n'
           '  Using cached docker-5.0.3-py2.py3-none-any.whl (146 kB)\n'
           'Collecting markupsafe<=2.0.1,>=1.1.1\n'
           '  Using cached MarkupSafe-2.0.1-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl (30 kB)\n'
           'Collecting python-dateutil>=2.8.0\n'
           '  Using cached python_dateutil-2.8.2-py2.py3-none-any.whl (247 kB)\n'
           'Collecting pydantic>=1.5.1\n'
           '  Using cached pydantic-1.9.1-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (12.4 MB)\n'
           'Collecting mixpanel>=4.9.0\n'
           '  Using cached mixpanel-4.9.0-py2.py3-none-any.whl (8.9 kB)\n'
           'Collecting progressbar2\n'
           '  Using cached progressbar2-4.0.0-py2.py3-none-any.whl (26 kB)\n'
           'Collecting types-Deprecated\n'
           '  Using cached types_Deprecated-1.2.8-py3-none-any.whl (3.1 kB)\n'
           'Collecting PyYAML\n'
           '  Using cached PyYAML-6.0-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl (661 kB)\n'
           'Collecting stackprinter\n'
           '  Using cached stackprinter-0.2.6-py3-none-any.whl (28 kB)\n'
           'Collecting packaging\n'
           '  Using cached packaging-21.3-py3-none-any.whl (40 kB)\n'
           'Collecting termcolor>=1.0.0\n'
           '  Using cached termcolor-1.1.0-py3-none-any.whl\n'
           'Collecting toml>=0.10.0\n'
           '  Using cached toml-0.10.2-py2.py3-none-any.whl (16 kB)\n'
           'Collecting click>=6.0.0\n'
           '  Using cached click-8.1.3-py3-none-any.whl (96 kB)\n'
           'Collecting requests\n'
           '  Using cached requests-2.28.0-py3-none-any.whl (62 kB)\n'
           'Collecting psycopg2-binary\n'
           '  Using cached psycopg2_binary-2.9.3-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (3.0 MB)\n'
           'Collecting traitlets<5.2.2\n'
           '  Using cached traitlets-5.2.1.post0-py3-none-any.whl (106 kB)\n'
           'Collecting greenlet\n'
           '  Using cached greenlet-1.1.2-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (153 kB)\n'
           'Collecting GeoAlchemy2\n'
           '  Using cached GeoAlchemy2-0.12.1-py2.py3-none-any.whl (50 kB)\n'
           'Collecting Jinja2<3.1.0\n'
           '  Using cached Jinja2-3.0.3-py3-none-any.whl (133 kB)\n'
           'Collecting sqlalchemy==1.3.24\n'
           '  Using cached SQLAlchemy-1.3.24-cp39-cp39-manylinux2010_x86_64.whl (1.3 MB)\n'
           'Collecting great-expectations<0.15.3,>=0.14.11\n'
           '  Using cached great_expectations-0.15.2-py3-none-any.whl (5.0 MB)\n'
           'Collecting tzlocal\n'
           '  Using cached tzlocal-4.2-py3-none-any.whl (19 kB)\n'
           'Collecting six\n'
           '  Using cached six-1.16.0-py2.py3-none-any.whl (11 kB)\n'
           'Collecting pytz\n'
           '  Using cached pytz-2022.1-py2.py3-none-any.whl (503 kB)\n'
           'Collecting urllib3<1.27,>=1.25.4\n'
           '  Using cached urllib3-1.26.9-py2.py3-none-any.whl (138 kB)\n'
           'Collecting Ipython>=7.16.3\n'
           '  Using cached ipython-8.4.0-py3-none-any.whl (750 kB)\n'
           'Collecting mistune>=0.8.4\n'
           '  Using cached mistune-2.0.2-py2.py3-none-any.whl (24 kB)\n'
           'Collecting numpy>=1.14.1\n'
           '  Using cached numpy-1.22.4-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (16.8 MB)\n'
           'Collecting cryptography>=3.2\n'
           '  Using cached cryptography-37.0.2-cp36-abi3-manylinux_2_24_x86_64.whl (4.0 MB)\n'
           'Collecting ruamel.yaml<0.17.18,>=0.16\n'
           '  Using cached ruamel.yaml-0.17.17-py3-none-any.whl (109 kB)\n'
           'Collecting scipy>=0.19.0\n'
           '  Using cached scipy-1.8.1-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (42.2 MB)\n'
           'Collecting jsonschema>=2.5.1\n'
           '  Using cached jsonschema-4.6.0-py3-none-any.whl (80 kB)\n'
           'Collecting nbformat>=5.0\n'
           '  Using cached nbformat-5.4.0-py3-none-any.whl (73 kB)\n'
           'Collecting colorama>=0.4.3\n'
           '  Using cached colorama-0.4.5-py2.py3-none-any.whl (16 kB)\n'
           'Collecting jsonpatch>=1.22\n'
           '  Using cached jsonpatch-1.32-py2.py3-none-any.whl (12 kB)\n'
           'Collecting notebook>=6.4.10\n'
           '  Using cached notebook-6.4.12-py3-none-any.whl (9.9 MB)\n'
           'Collecting altair<5,>=4.0.0\n'
           '  Using cached altair-4.2.0-py3-none-any.whl (812 kB)\n'
           'Collecting pyparsing<3,>=2.4\n'
           '  Using cached pyparsing-2.4.7-py2.py3-none-any.whl (67 kB)\n'
           'Collecting pandas>=0.23.0\n'
           '  Using cached pandas-1.4.2-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (11.7 MB)\n'
           'Collecting importlib-metadata>=1.7.0\n'
           '  Using cached importlib_metadata-4.11.4-py3-none-any.whl (18 kB)\n'
           'Collecting tqdm>=4.59.0\n'
           '  Using cached tqdm-4.64.0-py2.py3-none-any.whl (78 kB)\n'
           'Collecting certifi>=2017.4.17\n'
           '  Using cached certifi-2022.6.15-py3-none-any.whl (160 kB)\n'
           'Collecting charset-normalizer~=2.0.0\n'
           '  Using cached charset_normalizer-2.0.12-py3-none-any.whl (39 kB)\n'
           'Collecting idna<4,>=2.5\n'
           '  Using cached idna-3.3-py3-none-any.whl (61 kB)\n'
           'Collecting wrapt<2,>=1.10\n'
           '  Using cached wrapt-1.14.1-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl (77 kB)\n'
           'Collecting websocket-client>=0.32.0\n'
           '  Using cached websocket_client-1.3.3-py3-none-any.whl (54 kB)\n'
           'Collecting GeoAlchemy2\n'
           '  Using cached GeoAlchemy2-0.12.0-py2.py3-none-any.whl (50 kB)\n'
           '  Using cached GeoAlchemy2-0.11.1-py2.py3-none-any.whl (45 kB)\n'
           'Collecting python-utils>=3.0.0\n'
           '  Using cached python_utils-3.3.3-py2.py3-none-any.whl (23 kB)\n'
           'Collecting toolz\n'
           '  Using cached toolz-0.11.2-py3-none-any.whl (55 kB)\n'
           'Collecting cffi>=1.12\n'
           '  Using cached cffi-1.15.0-cp39-cp39-manylinux_2_12_x86_64.manylinux2010_x86_64.whl (444 kB)\n'
           'Collecting zipp>=0.5\n'
           '  Using cached zipp-3.8.0-py3-none-any.whl (5.4 kB)\n'
           'Collecting matplotlib-inline\n'
           '  Using cached matplotlib_inline-0.1.3-py3-none-any.whl (8.2 kB)\n'
           'Collecting pygments>=2.4.0\n'
           '  Using cached Pygments-2.12.0-py3-none-any.whl (1.1 MB)\n'
           'Collecting stack-data\n'
           '  Using cached stack_data-0.3.0-py3-none-any.whl (23 kB)\n'
           'Collecting backcall\n'
           '  Using cached backcall-0.2.0-py2.py3-none-any.whl (11 kB)\n'
           'Collecting pexpect>4.3\n'
           '  Using cached pexpect-4.8.0-py2.py3-none-any.whl (59 kB)\n'
           'Collecting pickleshare\n'
           '  Using cached pickleshare-0.7.5-py2.py3-none-any.whl (6.9 kB)\n'
           'Collecting jedi>=0.16\n'
           '  Using cached jedi-0.18.1-py2.py3-none-any.whl (1.6 MB)\n'
           'Requirement already satisfied: setuptools>=18.5 in '
           '/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages (from '
           'Ipython>=7.16.3->great-expectations<0.15.3,>=0.14.11->acryl-datahub[datahub-rest,postgres]==0.8.38->-r '
           '/tmp/datahub/ingest/requirements-c8714baa-5356-494b-8268-4b3c987419b2.txt (line 1)) (62.6.0)\n'
           'Collecting decorator\n'
           '  Using cached decorator-5.1.1-py3-none-any.whl (9.1 kB)\n'
           'Collecting prompt-toolkit!=3.0.0,!=3.0.1,<3.1.0,>=2.0.0\n'
           '  Using cached prompt_toolkit-3.0.29-py3-none-any.whl (381 kB)\n'
           'Collecting jsonpointer>=1.9\n'
           '  Using cached jsonpointer-2.3-py2.py3-none-any.whl (7.8 kB)\n'
           'Collecting pyrsistent!=0.17.0,!=0.17.1,!=0.17.2,>=0.14.0\n'
           '  Using cached pyrsistent-0.18.1-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (115 kB)\n'
           'Collecting attrs>=17.4.0\n'
           '  Using cached attrs-21.4.0-py2.py3-none-any.whl (60 kB)\n'
           'Collecting fastjsonschema\n'
           '  Using cached fastjsonschema-2.15.3-py3-none-any.whl (22 kB)\n'
           'Collecting jupyter-core\n'
           '  Using cached jupyter_core-4.10.0-py3-none-any.whl (87 kB)\n'
           'Collecting ipykernel\n'
           '  Using cached ipykernel-6.15.0-py3-none-any.whl (133 kB)\n'
           'Collecting Send2Trash>=1.8.0\n'
           '  Using cached Send2Trash-1.8.0-py3-none-any.whl (18 kB)\n'
           'Collecting ipython-genutils\n'
           '  Using cached ipython_genutils-0.2.0-py2.py3-none-any.whl (26 kB)\n'
           'Collecting jupyter-client>=5.3.4\n'
           '  Using cached jupyter_client-7.3.4-py3-none-any.whl (132 kB)\n'
           'Collecting nbconvert>=5\n'
           '  Using cached nbconvert-6.5.0-py3-none-any.whl (561 kB)\n'
           'Collecting prometheus-client\n'
           '  Using cached prometheus_client-0.14.1-py3-none-any.whl (59 kB)\n'
           'Collecting tornado>=6.1\n'
           '  Using cached tornado-6.1-cp39-cp39-manylinux2010_x86_64.whl (427 kB)\n'
           'Collecting argon2-cffi\n'
           '  Using cached argon2_cffi-21.3.0-py3-none-any.whl (14 kB)\n'
           'Collecting nest-asyncio>=1.5\n'
           '  Using cached nest_asyncio-1.5.5-py3-none-any.whl (5.2 kB)\n'
           'Collecting terminado>=0.8.3\n'
           '  Using cached terminado-0.15.0-py3-none-any.whl (16 kB)\n'
           'Collecting pyzmq>=17\n'
           '  Using cached pyzmq-23.2.0-cp39-cp39-manylinux_2_12_x86_64.manylinux2010_x86_64.whl (1.1 MB)\n'
           'Collecting ruamel.yaml.clib>=0.1.2\n'
           '  Using cached ruamel.yaml.clib-0.2.6-cp39-cp39-manylinux1_x86_64.whl (539 kB)\n'
           'Collecting pytz-deprecation-shim\n'
           '  Using cached pytz_deprecation_shim-0.1.0.post0-py2.py3-none-any.whl (15 kB)\n'
           'Collecting pycparser\n'
           '  Using cached pycparser-2.21-py2.py3-none-any.whl (118 kB)\n'
           'Collecting parso<0.9.0,>=0.8.0\n'
           '  Using cached parso-0.8.3-py2.py3-none-any.whl (100 kB)\n'
           'Collecting defusedxml\n'
           '  Using cached defusedxml-0.7.1-py2.py3-none-any.whl (25 kB)\n'
           'Collecting bleach\n'
           '  Using cached bleach-5.0.0-py3-none-any.whl (160 kB)\n'
           'Collecting beautifulsoup4\n'
           '  Using cached beautifulsoup4-4.11.1-py3-none-any.whl (128 kB)\n'
           'Collecting pandocfilters>=1.4.1\n'
           '  Using cached pandocfilters-1.5.0-py2.py3-none-any.whl (8.7 kB)\n'
           'Collecting jupyterlab-pygments\n'
           '  Using cached jupyterlab_pygments-0.2.2-py2.py3-none-any.whl (21 kB)\n'
           'Collecting mistune>=0.8.4\n'
           '  Using cached mistune-0.8.4-py2.py3-none-any.whl (16 kB)\n'
           'Collecting nbclient>=0.5.0\n'
           '  Using cached nbclient-0.6.4-py3-none-any.whl (71 kB)\n'
           'Collecting tinycss2\n'
           '  Using cached tinycss2-1.1.1-py3-none-any.whl (21 kB)\n'
           'Collecting ptyprocess>=0.5\n'
           '  Using cached ptyprocess-0.7.0-py2.py3-none-any.whl (13 kB)\n'
           'Collecting wcwidth\n'
           '  Using cached wcwidth-0.2.5-py2.py3-none-any.whl (30 kB)\n'
           'Collecting argon2-cffi-bindings\n'
           '  Using cached argon2_cffi_bindings-21.2.0-cp36-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (86 kB)\n'
           'Collecting debugpy>=1.0\n'
           '  Using cached debugpy-1.6.0-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl (1.8 MB)\n'
           'Collecting tzdata\n'
           '  Using cached tzdata-2022.1-py2.py3-none-any.whl (339 kB)\n'
           'Collecting asttokens\n'
           '  Using cached asttokens-2.0.5-py2.py3-none-any.whl (20 kB)\n'
           'Collecting pure-eval\n'
           '  Using cached pure_eval-0.2.2-py3-none-any.whl (11 kB)\n'
           'Collecting executing\n'
           '  Using cached executing-0.8.3-py2.py3-none-any.whl (16 kB)\n'
           'Collecting nbclient>=0.5.0\n'
           '  Using cached nbclient-0.6.3-py3-none-any.whl (71 kB)\n'
           'Collecting soupsieve>1.2\n'
           '  Using cached soupsieve-2.3.2.post1-py3-none-any.whl (37 kB)\n'
           'Collecting webencodings\n'
           '  Using cached webencodings-0.5.1-py2.py3-none-any.whl (11 kB)\n'
           'Installing collected packages: webencodings, wcwidth, types-termcolor, types-Deprecated, termcolor, tabulate, Send2Trash, ratelimiter, '
           'pytz, pure-eval, ptyprocess, pickleshare, mypy-extensions, mistune, ipython-genutils, fastjsonschema, executing, backcall, zipp, wrapt, '
           'websocket-client, urllib3, tzdata, typing-extensions, traitlets, tqdm, tornado, toolz, toml, tinycss2, stackprinter, sqlalchemy, '
           'soupsieve, six, ruamel.yaml.clib, pyzmq, PyYAML, python-utils, pyrsistent, pyparsing, pygments, pycparser, psycopg2-binary, psutil, '
           'prompt-toolkit, prometheus-client, pexpect, parso, pandocfilters, numpy, nest-asyncio, markupsafe, jupyterlab-pygments, jsonpointer, '
           'idna, humanfriendly, greenlet, expandvars, entrypoints, defusedxml, decorator, debugpy, colorama, click, charset-normalizer, certifi, '
           'avro, attrs, typing-inspect, terminado, scipy, ruamel.yaml, requests, pytz-deprecation-shim, python-dateutil, pydantic, progressbar2, '
           'packaging, matplotlib-inline, jupyter-core, jsonschema, jsonpatch, Jinja2, jedi, importlib-metadata, Deprecated, click-default-group, '
           'cffi, bleach, beautifulsoup4, asttokens, tzlocal, stack-data, pandas, nbformat, mixpanel, jupyter-client, GeoAlchemy2, docker, '
           'cryptography, argon2-cffi-bindings, nbclient, Ipython, avro-gen3, argon2-cffi, altair, nbconvert, ipykernel, acryl-datahub, notebook, '
           'great-expectations\n'
           'Successfully installed Deprecated-1.2.13 GeoAlchemy2-0.11.1 Ipython-8.4.0 Jinja2-3.0.3 PyYAML-6.0 Send2Trash-1.8.0 acryl-datahub-0.8.38 '
           'altair-4.2.0 argon2-cffi-21.3.0 argon2-cffi-bindings-21.2.0 asttokens-2.0.5 attrs-21.4.0 avro-1.10.2 avro-gen3-0.7.4 backcall-0.2.0 '
           'beautifulsoup4-4.11.1 bleach-5.0.0 certifi-2022.6.15 cffi-1.15.0 charset-normalizer-2.0.12 click-8.1.3 click-default-group-1.2.2 '
           'colorama-0.4.5 cryptography-37.0.2 debugpy-1.6.0 decorator-5.1.1 defusedxml-0.7.1 docker-5.0.3 entrypoints-0.4 executing-0.8.3 '
           'expandvars-0.9.0 fastjsonschema-2.15.3 great-expectations-0.15.2 greenlet-1.1.2 humanfriendly-10.0 idna-3.3 importlib-metadata-4.11.4 '
           'ipykernel-6.15.0 ipython-genutils-0.2.0 jedi-0.18.1 jsonpatch-1.32 jsonpointer-2.3 jsonschema-4.6.0 jupyter-client-7.3.4 '
           'jupyter-core-4.10.0 jupyterlab-pygments-0.2.2 markupsafe-2.0.1 matplotlib-inline-0.1.3 mistune-0.8.4 mixpanel-4.9.0 '
           'mypy-extensions-0.4.3 nbclient-0.6.3 nbconvert-6.5.0 nbformat-5.4.0 nest-asyncio-1.5.5 notebook-6.4.12 numpy-1.22.4 packaging-21.3 '
           'pandas-1.4.2 pandocfilters-1.5.0 parso-0.8.3 pexpect-4.8.0 pickleshare-0.7.5 progressbar2-4.0.0 prometheus-client-0.14.1 '
           'prompt-toolkit-3.0.29 psutil-5.9.1 psycopg2-binary-2.9.3 ptyprocess-0.7.0 pure-eval-0.2.2 pycparser-2.21 pydantic-1.9.1 pygments-2.12.0 '
           'pyparsing-2.4.7 pyrsistent-0.18.1 python-dateutil-2.8.2 python-utils-3.3.3 pytz-2022.1 pytz-deprecation-shim-0.1.0.post0 pyzmq-23.2.0 '
           'ratelimiter-1.2.0.post0 requests-2.28.0 ruamel.yaml-0.17.17 ruamel.yaml.clib-0.2.6 scipy-1.8.1 six-1.16.0 soupsieve-2.3.2.post1 '
           'sqlalchemy-1.3.24 stack-data-0.3.0 stackprinter-0.2.6 tabulate-0.8.9 termcolor-1.1.0 terminado-0.15.0 tinycss2-1.1.1 toml-0.10.2 '
           'toolz-0.11.2 tornado-6.1 tqdm-4.64.0 traitlets-5.2.1.post0 types-Deprecated-1.2.8 types-termcolor-1.1.4 typing-extensions-4.2.0 '
           'typing-inspect-0.7.1 tzdata-2022.1 tzlocal-4.2 urllib3-1.26.9 wcwidth-0.2.5 webencodings-0.5.1 websocket-client-1.3.3 wrapt-1.14.1 '
           'zipp-3.8.0\n'
           '[2022-06-20 14:11:22,529] INFO     {datahub.cli.ingest_cli:99} - DataHub CLI version: 0.8.38\n'
           '[2022-06-20 14:11:25,137] INFO     {datahub.cli.ingest_cli:115} - Starting metadata ingestion\n'
           '[2022-06-20 14:11:25,145] INFO     {datahub.cli.ingest_cli:119} - Source (postgres) report:\n'
           "{'workunits_produced': 0,\n"
           " 'workunit_ids': [],\n"
           " 'warnings': {},\n"
           " 'failures': {},\n"
           " 'cli_version': '0.8.38',\n"
           " 'cli_entry_location': '/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/__init__.py',\n"
           " 'py_version': '3.9.9 (main, Dec 21 2021, 10:03:34) \\n[GCC 10.2.1 20210110]',\n"
           " 'py_exec_path': '/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/bin/python3',\n"
           " 'os_details': 'Linux-5.13.0-51-generic-x86_64-with-glibc2.31',\n"
           " 'tables_scanned': 0,\n"
           " 'views_scanned': 0,\n"
           " 'entities_profiled': 0,\n"
           " 'filtered': [],\n"
           " 'soft_deleted_stale_entities': [],\n"
           " 'query_combiner': None}\n"
           '[2022-06-20 14:11:25,145] INFO     {datahub.cli.ingest_cli:122} - Sink (datahub-rest) report:\n'
           "{'records_written': 0,\n"
           " 'warnings': [],\n"
           " 'failures': [],\n"
           " 'downstream_start_time': None,\n"
           " 'downstream_end_time': None,\n"
           " 'downstream_total_latency_in_seconds': None,\n"
           " 'gms_version': 'v0.8.38'}\n"
           '[2022-06-20 14:11:25,909] ERROR    {datahub.entrypoints:167} - File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2336, in '
           '_wrap_pool_connect\n'
           '    2333  def _wrap_pool_connect(self, fn, connection):\n'
           '    2334      dialect = self.dialect\n'
           '    2335      try:\n'
           '--> 2336          return fn()\n'
           '    2337      except dialect.dbapi.Error as e:\n'
           '    ..................................................\n'
           '     self = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           "     fn = <method 'Pool.unique_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> base.py:292>\n"
           '     connection = None\n'
           '     dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     self.dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           "     dialect.dbapi.Error = <class 'psycopg2.Error'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 304, in '
           'unique_connection\n'
           '    292  def unique_connection(self):\n'
           ' (...)\n'
           '    300      method provides a means of bypassing\n'
           '    301      the threadlocal context.\n'
           '    302  \n'
           '    303      """\n'
           '--> 304      return _ConnectionFairy._checkout(self)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 778, in '
           '_checkout\n'
           '    775  @classmethod\n'
           '    776  def _checkout(cls, pool, threadconns=None, fairy=None):\n'
           '    777      if not fairy:\n'
           '--> 778          fairy = _ConnectionRecord.checkout(pool)\n'
           '    779  \n'
           '    ..................................................\n'
           "     cls = <class 'sqlalchemy.pool.base._ConnectionFairy'>\n"
           '     pool = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           '     threadconns = None\n'
           '     fairy = None\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 495, in '
           'checkout\n'
           '    493  @classmethod\n'
           '    494  def checkout(cls, pool):\n'
           '--> 495      rec = pool._do_get()\n'
           '    496      try:\n'
           '    ..................................................\n'
           "     cls = <class 'sqlalchemy.pool.base._ConnectionRecord'>\n"
           '     pool = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     pool._do_get = <method 'QueuePool._do_get' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> impl.py:113>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 140, in '
           '_do_get\n'
           '    113  def _do_get(self):\n'
           ' (...)\n'
           '    136          try:\n'
           '    137              return self._create_connection()\n'
           '    138          except:\n'
           '    139              with util.safe_reraise():\n'
           '--> 140                  self._dec_overflow()\n'
           '    141      else:\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     self._create_connection = <method 'Pool._create_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> "
           'base.py:306>\n'
           "     util.safe_reraise = <class 'sqlalchemy.util.langhelpers.safe_reraise'>\n"
           "     self._dec_overflow = <method 'QueuePool._dec_overflow' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> impl.py:155>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    62   def __exit__(self, type_, value, traceback):\n'
           ' (...)\n'
           '    64       if type_ is None:\n'
           '    65           exc_type, exc_value, exc_tb = self._exc_info\n'
           '    66           self._exc_info = None  # remove potential circular references\n'
           '    67           if not self.warn_only:\n'
           '--> 68               compat.raise_(\n'
           '    69                   exc_value,\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.util.langhelpers.safe_reraise object at 0x7f9e38ed0b80>\n'
           '     type_ = None\n'
           '     value = None\n'
           '     traceback = None\n'
           "     exc_type = <class 'psycopg2.OperationalError'>\n"
           '     exc_value = OperationalError(\'connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\\n\\tIs the '
           'server\n'
           '                   running on that host and accepting TCP/IP connections?\\nconnection to server at "localhost" (::1), port 5432 failed: '
           'Ca\n'
           "                  nnot assign requested address\\n\\tIs the server running on that host and accepting TCP/IP connections?\\n')\n"
           '     exc_tb = <traceback object at 0x7f9e38ef09c0>\n'
           '     self._exc_info = None\n'
           '     self.warn_only = False\n'
           "     compat.raise_ = <function 'raise_' compat.py:152>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    152  def raise_(\n'
           '    153      exception, with_traceback=None, replace_context=None, from_=False\n'
           '    154  ):\n'
           ' (...)\n'
           '    178          # that out.\n'
           '    179          exception.__cause__ = replace_context\n'
           '    180  \n'
           '    181      try:\n'
           '--> 182          raise exception\n'
           '    183      finally:\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 137, in '
           '_do_get\n'
           '    113  def _do_get(self):\n'
           ' (...)\n'
           '    133              )\n'
           '    134  \n'
           '    135      if self._inc_overflow():\n'
           '    136          try:\n'
           '--> 137              return self._create_connection()\n'
           '    138          except:\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     self._inc_overflow = <method 'QueuePool._inc_overflow' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> impl.py:144>\n"
           "     self._create_connection = <method 'Pool._create_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> "
           'base.py:306>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 309, in '
           '_create_connection\n'
           '    306  def _create_connection(self):\n'
           '    307      """Called by subclasses to create a new ConnectionRecord."""\n'
           '    308  \n'
           '--> 309      return _ConnectionRecord(self)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     _ConnectionRecord = <class 'sqlalchemy.pool.base._ConnectionRecord'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 440, in '
           '__init__\n'
           '    437  def __init__(self, pool, connect=True):\n'
           '    438      self.__pool = pool\n'
           '    439      if connect:\n'
           '--> 440          self.__connect(first_connect_check=True)\n'
           '    441      self.finalize_callback = deque()\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     pool = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           '     connect = True\n'
           '     self.__pool = # AttributeError\n'
           '          self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     self.__connect = # AttributeError\n'
           '          self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     self.finalize_callback = # AttributeError\n'
           '          self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           "     deque = <class 'collections.deque'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 661, in '
           '__connect\n'
           '    648  def __connect(self, first_connect_check=False):\n'
           ' (...)\n'
           '    657          pool.logger.debug("Created new connection %r", connection)\n'
           '    658          self.connection = connection\n'
           '    659      except Exception as e:\n'
           '    660          with util.safe_reraise():\n'
           '--> 661              pool.logger.debug("Error on connect(): %s", e)\n'
           '    662      else:\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     first_connect_check = True\n'
           "     pool.logger.debug = <method 'Logger.debug' of <Logger sqlalchemy.pool.impl.QueuePool (WARNING)> __init__.py:1424>\n"
           '     self.connection = None\n'
           "     util.safe_reraise = <class 'sqlalchemy.util.langhelpers.safe_reraise'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    62   def __exit__(self, type_, value, traceback):\n'
           ' (...)\n'
           '    64       if type_ is None:\n'
           '    65           exc_type, exc_value, exc_tb = self._exc_info\n'
           '    66           self._exc_info = None  # remove potential circular references\n'
           '    67           if not self.warn_only:\n'
           '--> 68               compat.raise_(\n'
           '    69                   exc_value,\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.util.langhelpers.safe_reraise object at 0x7f9e38ed0760>\n'
           '     type_ = None\n'
           '     value = None\n'
           '     traceback = None\n'
           "     exc_type = <class 'psycopg2.OperationalError'>\n"
           '     exc_value = OperationalError(\'connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\\n\\tIs the '
           'server\n'
           '                   running on that host and accepting TCP/IP connections?\\nconnection to server at "localhost" (::1), port 5432 failed: '
           'Ca\n'
           "                  nnot assign requested address\\n\\tIs the server running on that host and accepting TCP/IP connections?\\n')\n"
           '     exc_tb = <traceback object at 0x7f9e38ef0880>\n'
           '     self._exc_info = None\n'
           '     self.warn_only = False\n'
           "     compat.raise_ = <function 'raise_' compat.py:152>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    152  def raise_(\n'
           '    153      exception, with_traceback=None, replace_context=None, from_=False\n'
           '    154  ):\n'
           ' (...)\n'
           '    178          # that out.\n'
           '    179          exception.__cause__ = replace_context\n'
           '    180  \n'
           '    181      try:\n'
           '--> 182          raise exception\n'
           '    183      finally:\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 656, in '
           '__connect\n'
           '    648  def __connect(self, first_connect_check=False):\n'
           ' (...)\n'
           '    652      # creator fails, this attribute stays None\n'
           '    653      self.connection = None\n'
           '    654      try:\n'
           '    655          self.starttime = time.time()\n'
           '--> 656          connection = pool._invoke_creator(self)\n'
           '    657          pool.logger.debug("Created new connection %r", connection)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     first_connect_check = True\n'
           '     self.connection = None\n'
           '     self.starttime = 1655734285.144904\n'
           "     pool._invoke_creator = <function 'DefaultEngineStrategy.create.<locals>.connect' strategies.py:106>\n"
           "     pool.logger.debug = <method 'Logger.debug' of <Logger sqlalchemy.pool.impl.QueuePool (WARNING)> __init__.py:1424>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/strategies.py", line '
           '114, in connect\n'
           '    106  def connect(connection_record=None):\n'
           ' (...)\n'
           '    110                  dialect, connection_record, cargs, cparams\n'
           '    111              )\n'
           '    112              if connection is not None:\n'
           '    113                  return connection\n'
           '--> 114      return dialect.connect(*cargs, **cparams)\n'
           '    ..................................................\n'
           '     connection_record = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     cargs = []\n'
           "     cparams = {'host': 'localhost',\n"
           "                'database': 'analysis',\n"
           "                'user': 'postgres',\n"
           "                'password': 'tungdq_vng',\n"
           "                'port': 5432}\n"
           "     dialect.connect = <method 'DefaultDialect.connect' of <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at "
           '0x7f9e38f47fa0\n'
           '                        > default.py:506>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/default.py", line 508, '
           'in connect\n'
           '    506  def connect(self, *cargs, **cparams):\n'
           '    507      # inherits the docstring from interfaces.Dialect.connect\n'
           '--> 508      return self.dbapi.connect(*cargs, **cparams)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     cargs = ()\n'
           "     cparams = {'host': 'localhost',\n"
           "                'database': 'analysis',\n"
           "                'user': 'postgres',\n"
           "                'password': 'tungdq_vng',\n"
           "                'port': 5432}\n"
           "     self.dbapi.connect = <function 'connect' __init__.py:80>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/psycopg2/__init__.py", line 122, in '
           'connect\n'
           '    80   def connect(dsn=None, connection_factory=None, cursor_factory=None, **kwargs):\n'
           ' (...)\n'
           "    118      if 'async_' in kwargs:\n"
           "    119          kwasync['async_'] = kwargs.pop('async_')\n"
           '    120  \n'
           '    121      dsn = _ext.make_dsn(dsn, **kwargs)\n'
           '--> 122      conn = _connect(dsn, connection_factory=connection_factory, **kwasync)\n'
           '    123      if cursor_factory is not None:\n'
           '    ..................................................\n'
           "     dsn = 'host=localhost user=postgres password=tungdq_vng port=5432 dbname=analysis'\n"
           '     connection_factory = None\n'
           '     cursor_factory = None\n'
           "     kwargs = {'host': 'localhost',\n"
           "               'database': 'analysis',\n"
           "               'user': 'postgres',\n"
           "               'password': 'tungdq_vng',\n"
           "               'port': 5432}\n"
           '     kwasync = {}\n'
           "     _ext.make_dsn = <function 'make_dsn' extensions.py:138>\n"
           '    ..................................................\n'
           '\n'
           '---- (full traceback above) ----\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2336, '
           'in _wrap_pool_connect\n'
           '    return fn()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 304, in '
           'unique_connection\n'
           '    return _ConnectionFairy._checkout(self)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 778, in '
           '_checkout\n'
           '    fairy = _ConnectionRecord.checkout(pool)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 495, in '
           'checkout\n'
           '    rec = pool._do_get()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 140, in '
           '_do_get\n'
           '    self._dec_overflow()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    compat.raise_(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    raise exception\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 137, in '
           '_do_get\n'
           '    return self._create_connection()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 309, in '
           '_create_connection\n'
           '    return _ConnectionRecord(self)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 440, in '
           '__init__\n'
           '    self.__connect(first_connect_check=True)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 661, in '
           '__connect\n'
           '    pool.logger.debug("Error on connect(): %s", e)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    compat.raise_(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    raise exception\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 656, in '
           '__connect\n'
           '    connection = pool._invoke_creator(self)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/strategies.py", line '
           '114, in connect\n'
           '    return dialect.connect(*cargs, **cparams)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/default.py", line 508, '
           'in connect\n'
           '    return self.dbapi.connect(*cargs, **cparams)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/psycopg2/__init__.py", line 122, in '
           'connect\n'
           '    conn = _connect(dsn, connection_factory=connection_factory, **kwasync)\n'
           '\n'
           'OperationalError: connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\n'
           '\tIs the server running on that host and accepting TCP/IP connections?\n'
           'connection to server at "localhost" (::1), port 5432 failed: Cannot assign requested address\n'
           '\tIs the server running on that host and accepting TCP/IP connections?\n'
           '\n'
           '\n'
           'The above exception was the direct cause of the following exception:\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/entrypoints.py", line 149, in '
           'main\n'
           '    146  def main(**kwargs):\n'
           '    147      # This wrapper prevents click from suppressing errors.\n'
           '    148      try:\n'
           '--> 149          sys.exit(datahub(standalone_mode=False, **kwargs))\n'
           '    150      except click.exceptions.Abort:\n'
           '    ..................................................\n'
           '     kwargs = {}\n'
           '     datahub = <Group datahub>\n'
           "     click.exceptions.Abort = <class 'click.exceptions.Abort'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1130, in __call__\n'
           '    1128  def __call__(self, *args: t.Any, **kwargs: t.Any) -> t.Any:\n'
           ' (...)\n'
           '--> 1130      return self.main(*args, **kwargs)\n'
           '    ..................................................\n'
           '     self = <Group datahub>\n'
           '     args = ()\n'
           '     t.Any = typing.Any\n'
           "     kwargs = {'standalone_mode': False,\n"
           "               'prog_name': 'python3 -m datahub'}\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1055, in main\n'
           '    rv = self.invoke(ctx)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1657, in invoke\n'
           '    return _process_result(sub_ctx.command.invoke(sub_ctx))\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1657, in invoke\n'
           '    return _process_result(sub_ctx.command.invoke(sub_ctx))\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1404, in invoke\n'
           '    return ctx.invoke(self.callback, **ctx.params)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 760, in invoke\n'
           '    return __callback(*args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/decorators.py", line 26, in '
           'new_func\n'
           '    return f(get_current_context(), *args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/upgrade/upgrade.py", line 333, '
           'in wrapper\n'
           '    330  @wraps(func)\n'
           '    331  def wrapper(*args: Any, **kwargs: Any) -> Any:\n'
           '    332  \n'
           '--> 333      res = func(*args, **kwargs)\n'
           '    334      try:\n'
           '    ..................................................\n'
           "     func = <function 'run' telemetry.py:280>\n"
           '     args = (<click.core.Context object at 0x7f9e4e438f10>, )\n'
           '     Any = typing.Any\n'
           "     kwargs = {'config': '/tmp/datahub/ingest/c8714baa-5356-494b-8268-4b3c987419b2.yml',\n"
           "               'dry_run': False,\n"
           "               'preview': False,\n"
           "               'preview_workunits': 10,\n"
           "               'strict_warnings': False,\n"
           "               'suppress_error_logs': False}\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/telemetry/telemetry.py", line '
           '338, in wrapper\n'
           '    281  def wrapper(*args: Any, **kwargs: Any) -> Any:\n'
           ' (...)\n'
           '    334                  "status": "error",\n'
           '    335                  "error": get_full_class_name(e),\n'
           '    336              },\n'
           '    337          )\n'
           '--> 338          raise e\n'
           '    ..................................................\n'
           '     args = (<click.core.Context object at 0x7f9e4e438f10>, )\n'
           '     Any = typing.Any\n'
           "     kwargs = {'config': '/tmp/datahub/ingest/c8714baa-5356-494b-8268-4b3c987419b2.yml',\n"
           "               'dry_run': False,\n"
           "               'preview': False,\n"
           "               'preview_workunits': 10,\n"
           "               'strict_warnings': False,\n"
           "               'suppress_error_logs': False}\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/telemetry/telemetry.py", line '
           '290, in wrapper\n'
           '    281  def wrapper(*args: Any, **kwargs: Any) -> Any:\n'
           ' (...)\n'
           '    286      telemetry_instance.ping(\n'
           '    287          "function-call", {"function": function, "status": "start"}\n'
           '    288      )\n'
           '    289      try:\n'
           '--> 290          res = func(*args, **kwargs)\n'
           '    291          telemetry_instance.ping(\n'
           '    ..................................................\n'
           '     args = (<click.core.Context object at 0x7f9e4e438f10>, )\n'
           '     Any = typing.Any\n'
           "     kwargs = {'config': '/tmp/datahub/ingest/c8714baa-5356-494b-8268-4b3c987419b2.yml',\n"
           "               'dry_run': False,\n"
           "               'preview': False,\n"
           "               'preview_workunits': 10,\n"
           "               'strict_warnings': False,\n"
           "               'suppress_error_logs': False}\n"
           "     telemetry_instance.ping = <method 'Telemetry.ping' of <datahub.telemetry.telemetry.Telemetry object at 0x7f9e4e6371c0> "
           'telemetry.py:215>\n'
           "     function = 'datahub.cli.ingest_cli.run'\n"
           "     func = <function 'run' memory_leak_detector.py:92>\n"
           '    ..................................................\n'
           '\n'
           'File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/utilities/memory_leak_detector.py", '
           'line 102, in wrapper\n'
           '    93   def wrapper(*args: Any, **kwargs: Any) -> Any:\n'
           ' (...)\n'
           '    98           )\n'
           '    99           _init_leak_detection()\n'
           '    100  \n'
           '    101      try:\n'
           '--> 102          res = func(*args, **kwargs)\n'
           '    103          return res\n'
           '    ..................................................\n'
           '     args = (<click.core.Context object at 0x7f9e4e438f10>, )\n'
           '     Any = typing.Any\n'
           "     kwargs = {'config': '/tmp/datahub/ingest/c8714baa-5356-494b-8268-4b3c987419b2.yml',\n"
           "               'dry_run': False,\n"
           "               'preview': False,\n"
           "               'preview_workunits': 10,\n"
           "               'strict_warnings': False,\n"
           "               'suppress_error_logs': False}\n"
           "     func = <function 'run' ingest_cli.py:43>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/cli/ingest_cli.py", line 131, in '
           'run\n'
           '    88   def run(\n'
           '    89       ctx: click.Context,\n'
           '    90       config: str,\n'
           '    91       dry_run: bool,\n'
           '    92       preview: bool,\n'
           '    93       strict_warnings: bool,\n'
           '    94       preview_workunits: int,\n'
           '    95       suppress_error_logs: bool,\n'
           '    96   ) -> None:\n'
           ' (...)\n'
           '    127          # with `--suppress-error-logs` flag.\n'
           '    128          if suppress_error_logs:\n'
           '    129              raise SensitiveError() from e\n'
           '    130          else:\n'
           '--> 131              raise e\n'
           '    132      else:\n'
           '    ..................................................\n'
           '     run = <Command run>\n'
           '     ctx = <click.core.Context object at 0x7f9e4e438f10>\n'
           "     click.Context = <class 'click.core.Context'>\n"
           "     config = '/tmp/datahub/ingest/c8714baa-5356-494b-8268-4b3c987419b2.yml'\n"
           '     dry_run = False\n'
           '     preview = False\n'
           '     strict_warnings = False\n'
           '     preview_workunits = 10\n'
           '     suppress_error_logs = False\n'
           "     SensitiveError = <class 'datahub.configuration.common.SensitiveError'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/cli/ingest_cli.py", line 117, in '
           'run\n'
           '    88   def run(\n'
           '    89       ctx: click.Context,\n'
           '    90       config: str,\n'
           '    91       dry_run: bool,\n'
           '    92       preview: bool,\n'
           '    93       strict_warnings: bool,\n'
           '    94       preview_workunits: int,\n'
           '    95       suppress_error_logs: bool,\n'
           '    96   ) -> None:\n'
           ' (...)\n'
           '    113          raise SensitiveError() from e\n'
           '    114  \n'
           '    115      logger.info("Starting metadata ingestion")\n'
           '    116      try:\n'
           '--> 117          pipeline.run()\n'
           '    118      except Exception as e:\n'
           '    ..................................................\n'
           '     run = <Command run>\n'
           '     ctx = <click.core.Context object at 0x7f9e4e438f10>\n'
           "     click.Context = <class 'click.core.Context'>\n"
           "     config = '/tmp/datahub/ingest/c8714baa-5356-494b-8268-4b3c987419b2.yml'\n"
           '     dry_run = False\n'
           '     preview = False\n'
           '     strict_warnings = False\n'
           '     preview_workunits = 10\n'
           '     suppress_error_logs = False\n'
           "     SensitiveError = <class 'datahub.configuration.common.SensitiveError'>\n"
           "     logger.info = <method 'Logger.info' of <Logger datahub.cli.ingest_cli (INFO)> __init__.py:1436>\n"
           "     pipeline.run = <method 'Pipeline.run' of <datahub.ingestion.run.pipeline.Pipeline object at 0x7f9e4e438df0> pipeline.py:209>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/ingestion/run/pipeline.py", line '
           '213, in run\n'
           '    209  def run(self) -> None:\n'
           '    210  \n'
           '    211      callback = LoggingCallback()\n'
           '    212      extractor: Extractor = self.extractor_class()\n'
           '--> 213      for wu in itertools.islice(\n'
           '    214          self.source.get_workunits(),\n'
           '    ..................................................\n'
           '     self = <datahub.ingestion.run.pipeline.Pipeline object at 0x7f9e4e438df0>\n'
           '     callback = <datahub.ingestion.run.pipeline.LoggingCallback object at 0x7f9e4e3a9790>\n'
           "     LoggingCallback = <class 'datahub.ingestion.run.pipeline.LoggingCallback'>\n"
           '     extractor = <datahub.ingestion.extractor.mce_extractor.WorkUnitRecordExtractor object at 0x7f9e38f47e50>\n'
           "     Extractor = <class 'datahub.ingestion.api.source.Extractor'>\n"
           "     self.extractor_class = <class 'datahub.ingestion.extractor.mce_extractor.WorkUnitRecordExtractor'>\n"
           "     itertools.islice = <class 'itertools.islice'>\n"
           "     self.source.get_workunits = <method 'SQLAlchemySource.get_workunits' of "
           'PostgresSource(ctx=<datahub.ingestion.api.common.PipelineContext object at 0\n'
           '                                  x7f9e4e3f9430>) sql_common.py:697>\n'
           '    ..................................................\n'
           '\n'
           'File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/ingestion/source/sql/sql_common.py", '
           'line 710, in get_workunits\n'
           '    697  def get_workunits(self) -> Iterable[Union[MetadataWorkUnit, SqlWorkUnit]]:\n'
           ' (...)\n'
           '    706          sql_config.options.setdefault(\n'
           '    707              "max_overflow", sql_config.profiling.max_workers\n'
           '    708          )\n'
           '    709  \n'
           '--> 710      for inspector in self.get_inspectors():\n'
           '    711          profiler = None\n'
           '    ..................................................\n'
           '     self = PostgresSource(ctx=<datahub.ingestion.api.common.PipelineContext object at 0x7f9e4e3f9430>)\n'
           '     Iterable = typing.Iterable\n'
           '     Union = typing.Union\n'
           "     MetadataWorkUnit = <class 'datahub.ingestion.api.workunit.MetadataWorkUnit'>\n"
           "     SqlWorkUnit = <class 'datahub.ingestion.source.sql.sql_common.SqlWorkUnit'>\n"
           '     sql_config.profiling.max_workers = 40\n'
           "     self.get_inspectors = <method 'SQLAlchemySource.get_inspectors' of PostgresSource(ctx=<datahub.ingestion.api.common.PipelineContext "
           'object at \n'
           '                            0x7f9e4e3f9430>) sql_common.py:507>\n'
           '    ..................................................\n'
           '\n'
           'File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/ingestion/source/sql/sql_common.py", '
           'line 514, in get_inspectors\n'
           '    507  def get_inspectors(self) -> Iterable[Inspector]:\n'
           ' (...)\n'
           '    510  \n'
           '    511      url = self.config.get_sql_alchemy_url()\n'
           '    512      logger.debug(f"sql_alchemy_url={url}")\n'
           '    513      engine = create_engine(url, **self.config.options)\n'
           '--> 514      with engine.connect() as conn:\n'
           '    515          inspector = inspect(conn)\n'
           '    ..................................................\n'
           '     self = PostgresSource(ctx=<datahub.ingestion.api.common.PipelineContext object at 0x7f9e4e3f9430>)\n'
           '     Iterable = typing.Iterable\n'
           "     Inspector = <class 'sqlalchemy.engine.reflection.Inspector'>\n"
           "     url = 'postgresql+psycopg2://postgres:tungdq_vng@localhost:5432/analysis'\n"
           "     self.config.get_sql_alchemy_url = <method 'BasicSQLAlchemyConfig.get_sql_alchemy_url' of env='PROD' platform=None "
           'platform_instance=None stateful_ingestio\n'
           "                                        n=None options={} schema_pattern=AllowDenyPattern(allow=['.*'], deny=['information_schema'], "
           "ignoreCase=True, alphabet='\n"
           "                                        [A-Za-z0-9 _.-]') table_pattern=AllowDenyPattern(allow=['.*'], deny=[], ignoreCase=True, "
           "alphabet='[A-Za-z0-9 _.-]') vie\n"
           "                                        w_pattern=AllowDenyPattern(allow=['.*'], deny=[], ignoreCase=True, alphabet='[A-Za-z0-9 _.-]') "
           'profile_pattern=AllowDeny\n'
           "                                        Pattern(allow=['.*'], deny=[], ignoreCase=True, alphabet='[A-Za-z0-9 _.-]') domain={} "
           'include_views=True include_tables=\n'
           '                                        True profiling=GEProfilingConfig(enabled=False, limit=None, offset=None, '
           'report_dropped_profiles=False, turn_off_expensi\n'
           '                                        ve_profiling_metrics=False, profile_table_level_only=False, include_field_null_count=True, '
           'include_field_min_value=True,\n'
           '                                         include_field_max_value=True, include_field_mean_value=True, include_field_median_value=True, '
           'include_field_stddev_valu\n'
           '                                        e=True, include_field_quantiles=False, include_field_distinct_value_frequencies=False, '
           'include_field_histogram=False, in\n'
           "                                        clude_field_sample_values=True, allow_deny_patterns=AllowDenyPattern(allow=['.*'], deny=[], "
           "ignoreCase=True, alphabet='[\n"
           '                                        ...\n'
           "     logger.debug = <method 'Logger.debug' of <Logger datahub.ingestion.source.sql.sql_common (INFO)> __init__.py:1424>\n"
           '     engine = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           '     self.config.options = {}\n'
           "     engine.connect = <method 'Engine.connect' of Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis) base.py:2248>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2263, '
           'in connect\n'
           '    2248  def connect(self, **kwargs):\n'
           ' (...)\n'
           '    2259      :meth:`_engine.Engine.connect`.\n'
           '    2260  \n'
           '    2261      """\n'
           '    2262  \n'
           '--> 2263      return self._connection_cls(self, **kwargs)\n'
           '    ..................................................\n'
           '     self = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           '     kwargs = {}\n'
           "     self._connection_cls = <class 'sqlalchemy.engine.base.Connection'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 104, in '
           '__init__\n'
           '    70   def __init__(\n'
           '    71       self,\n'
           '    72       engine,\n'
           '    73       connection=None,\n'
           '    74       close_with_result=False,\n'
           '    75       _branch_from=None,\n'
           '    76       _execution_options=None,\n'
           '    77       _dispatch=None,\n'
           '    78       _has_events=None,\n'
           '    79   ):\n'
           ' (...)\n'
           '    100      else:\n'
           '    101          self.__connection = (\n'
           '    102              connection\n'
           '    103              if connection is not None\n'
           '--> 104              else engine.raw_connection()\n'
           '    105          )\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.engine.base.Connection object at 0x7f9e38f47ca0>\n'
           '     engine = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           '     connection = None\n'
           '     close_with_result = False\n'
           '     _branch_from = None\n'
           '     _execution_options = None\n'
           '     _dispatch = None\n'
           '     _has_events = None\n'
           '     self.__connection = # AttributeError\n'
           '          self = <sqlalchemy.engine.base.Connection object at 0x7f9e38f47ca0>\n'
           "     engine.raw_connection = <method 'Engine.raw_connection' of Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis) "
           'base.py:2347>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2369, '
           'in raw_connection\n'
           '    2347  def raw_connection(self, _connection=None):\n'
           ' (...)\n'
           '    2365  \n'
           '    2366          :ref:`dbapi_connections`\n'
           '    2367  \n'
           '    2368      """\n'
           '--> 2369      return self._wrap_pool_connect(\n'
           '    2370          self.pool.unique_connection, _connection\n'
           '    ..................................................\n'
           '     self = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           '     _connection = None\n'
           "     self._wrap_pool_connect = <method 'Engine._wrap_pool_connect' of Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis) "
           'base.py:2333>\n'
           "     self.pool.unique_connection = <method 'Pool.unique_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> "
           'base.py:292>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2339, '
           'in _wrap_pool_connect\n'
           '    2333  def _wrap_pool_connect(self, fn, connection):\n'
           ' (...)\n'
           '    2335      try:\n'
           '    2336          return fn()\n'
           '    2337      except dialect.dbapi.Error as e:\n'
           '    2338          if connection is None:\n'
           '--> 2339              Connection._handle_dbapi_exception_noconnection(\n'
           '    2340                  e, dialect, self\n'
           '    ..................................................\n'
           '     self = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           "     fn = <method 'Pool.unique_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> base.py:292>\n"
           '     connection = None\n'
           "     dialect.dbapi.Error = <class 'psycopg2.Error'>\n"
           '     dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 1583, '
           'in _handle_dbapi_exception_noconnection\n'
           '    1529  def _handle_dbapi_exception_noconnection(cls, e, dialect, engine):\n'
           ' (...)\n'
           '    1579  \n'
           '    1580      if newraise:\n'
           '    1581          util.raise_(newraise, with_traceback=exc_info[2], from_=e)\n'
           '    1582      elif should_wrap:\n'
           '--> 1583          util.raise_(\n'
           '    1584              sqlalchemy_exception, with_traceback=exc_info[2], from_=e\n'
           '    ..................................................\n'
           "     cls = <class 'sqlalchemy.engine.base.Connection'>\n"
           '     e = OperationalError(\'connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\\n\\tIs the server\n'
           '           running on that host and accepting TCP/IP connections?\\nconnection to server at "localhost" (::1), port 5432 failed: Ca\n'
           "          nnot assign requested address\\n\\tIs the server running on that host and accepting TCP/IP connections?\\n')\n"
           '     dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     engine = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           '     newraise = None\n'
           "     util.raise_ = <function 'raise_' compat.py:152>\n"
           '     exc_info = (<class \'psycopg2.OperationalError\'>, OperationalError(\'connection to server at "localhost" (127.0.0.1), port 5432 '
           'faile\n'
           '                 d: Connection refused\\n\\tIs the server running on that host and accepting TCP/IP connections?\\nconnection to server '
           'at "\n'
           '                 localhost" (::1), port 5432 failed: Cannot assign requested address\\n\\tIs the server running on that host and '
           'accepting \n'
           "                 TCP/IP connections?\\n'), <traceback object at 0x7f9e38ef0b00>, )\n"
           '     should_wrap = True\n'
           '     sqlalchemy_exception = OperationalError(\'(psycopg2.OperationalError) connection to server at "localhost" (127.0.0.1), port 5432 '
           'failed: Connect\n'
           '                             ion refused\\n\\tIs the server running on that host and accepting TCP/IP connections?\\nconnection to '
           'server at "localhost"\n'
           '                              (::1), port 5432 failed: Cannot assign requested address\\n\\tIs the server running on that host and '
           'accepting TCP/IP con\n'
           "                             nections?\\n')\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    152  def raise_(\n'
           '    153      exception, with_traceback=None, replace_context=None, from_=False\n'
           '    154  ):\n'
           ' (...)\n'
           '    178          # that out.\n'
           '    179          exception.__cause__ = replace_context\n'
           '    180  \n'
           '    181      try:\n'
           '--> 182          raise exception\n'
           '    183      finally:\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2336, '
           'in _wrap_pool_connect\n'
           '    2333  def _wrap_pool_connect(self, fn, connection):\n'
           '    2334      dialect = self.dialect\n'
           '    2335      try:\n'
           '--> 2336          return fn()\n'
           '    2337      except dialect.dbapi.Error as e:\n'
           '    ..................................................\n'
           '     self = Engine(postgresql+psycopg2://postgres:***@localhost:5432/analysis)\n'
           "     fn = <method 'Pool.unique_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> base.py:292>\n"
           '     connection = None\n'
           '     dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     self.dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           "     dialect.dbapi.Error = <class 'psycopg2.Error'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 304, in '
           'unique_connection\n'
           '    292  def unique_connection(self):\n'
           ' (...)\n'
           '    300      method provides a means of bypassing\n'
           '    301      the threadlocal context.\n'
           '    302  \n'
           '    303      """\n'
           '--> 304      return _ConnectionFairy._checkout(self)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 778, in '
           '_checkout\n'
           '    775  @classmethod\n'
           '    776  def _checkout(cls, pool, threadconns=None, fairy=None):\n'
           '    777      if not fairy:\n'
           '--> 778          fairy = _ConnectionRecord.checkout(pool)\n'
           '    779  \n'
           '    ..................................................\n'
           "     cls = <class 'sqlalchemy.pool.base._ConnectionFairy'>\n"
           '     pool = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           '     threadconns = None\n'
           '     fairy = None\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 495, in '
           'checkout\n'
           '    493  @classmethod\n'
           '    494  def checkout(cls, pool):\n'
           '--> 495      rec = pool._do_get()\n'
           '    496      try:\n'
           '    ..................................................\n'
           "     cls = <class 'sqlalchemy.pool.base._ConnectionRecord'>\n"
           '     pool = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     pool._do_get = <method 'QueuePool._do_get' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> impl.py:113>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 140, in '
           '_do_get\n'
           '    113  def _do_get(self):\n'
           ' (...)\n'
           '    136          try:\n'
           '    137              return self._create_connection()\n'
           '    138          except:\n'
           '    139              with util.safe_reraise():\n'
           '--> 140                  self._dec_overflow()\n'
           '    141      else:\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     self._create_connection = <method 'Pool._create_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> "
           'base.py:306>\n'
           "     util.safe_reraise = <class 'sqlalchemy.util.langhelpers.safe_reraise'>\n"
           "     self._dec_overflow = <method 'QueuePool._dec_overflow' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> impl.py:155>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    62   def __exit__(self, type_, value, traceback):\n'
           ' (...)\n'
           '    64       if type_ is None:\n'
           '    65           exc_type, exc_value, exc_tb = self._exc_info\n'
           '    66           self._exc_info = None  # remove potential circular references\n'
           '    67           if not self.warn_only:\n'
           '--> 68               compat.raise_(\n'
           '    69                   exc_value,\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.util.langhelpers.safe_reraise object at 0x7f9e38ed0b80>\n'
           '     type_ = None\n'
           '     value = None\n'
           '     traceback = None\n'
           "     exc_type = <class 'psycopg2.OperationalError'>\n"
           '     exc_value = OperationalError(\'connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\\n\\tIs the '
           'server\n'
           '                   running on that host and accepting TCP/IP connections?\\nconnection to server at "localhost" (::1), port 5432 failed: '
           'Ca\n'
           "                  nnot assign requested address\\n\\tIs the server running on that host and accepting TCP/IP connections?\\n')\n"
           '     exc_tb = <traceback object at 0x7f9e38ef09c0>\n'
           '     self._exc_info = None\n'
           '     self.warn_only = False\n'
           "     compat.raise_ = <function 'raise_' compat.py:152>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    152  def raise_(\n'
           '    153      exception, with_traceback=None, replace_context=None, from_=False\n'
           '    154  ):\n'
           ' (...)\n'
           '    178          # that out.\n'
           '    179          exception.__cause__ = replace_context\n'
           '    180  \n'
           '    181      try:\n'
           '--> 182          raise exception\n'
           '    183      finally:\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 137, in '
           '_do_get\n'
           '    113  def _do_get(self):\n'
           ' (...)\n'
           '    133              )\n'
           '    134  \n'
           '    135      if self._inc_overflow():\n'
           '    136          try:\n'
           '--> 137              return self._create_connection()\n'
           '    138          except:\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     self._inc_overflow = <method 'QueuePool._inc_overflow' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> impl.py:144>\n"
           "     self._create_connection = <method 'Pool._create_connection' of <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400> "
           'base.py:306>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 309, in '
           '_create_connection\n'
           '    306  def _create_connection(self):\n'
           '    307      """Called by subclasses to create a new ConnectionRecord."""\n'
           '    308  \n'
           '--> 309      return _ConnectionRecord(self)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           "     _ConnectionRecord = <class 'sqlalchemy.pool.base._ConnectionRecord'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 440, in '
           '__init__\n'
           '    437  def __init__(self, pool, connect=True):\n'
           '    438      self.__pool = pool\n'
           '    439      if connect:\n'
           '--> 440          self.__connect(first_connect_check=True)\n'
           '    441      self.finalize_callback = deque()\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     pool = <sqlalchemy.pool.impl.QueuePool object at 0x7f9e38ed0400>\n'
           '     connect = True\n'
           '     self.__pool = # AttributeError\n'
           '          self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     self.__connect = # AttributeError\n'
           '          self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     self.finalize_callback = # AttributeError\n'
           '          self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           "     deque = <class 'collections.deque'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 661, in '
           '__connect\n'
           '    648  def __connect(self, first_connect_check=False):\n'
           ' (...)\n'
           '    657          pool.logger.debug("Created new connection %r", connection)\n'
           '    658          self.connection = connection\n'
           '    659      except Exception as e:\n'
           '    660          with util.safe_reraise():\n'
           '--> 661              pool.logger.debug("Error on connect(): %s", e)\n'
           '    662      else:\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     first_connect_check = True\n'
           "     pool.logger.debug = <method 'Logger.debug' of <Logger sqlalchemy.pool.impl.QueuePool (WARNING)> __init__.py:1424>\n"
           '     self.connection = None\n'
           "     util.safe_reraise = <class 'sqlalchemy.util.langhelpers.safe_reraise'>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    62   def __exit__(self, type_, value, traceback):\n'
           ' (...)\n'
           '    64       if type_ is None:\n'
           '    65           exc_type, exc_value, exc_tb = self._exc_info\n'
           '    66           self._exc_info = None  # remove potential circular references\n'
           '    67           if not self.warn_only:\n'
           '--> 68               compat.raise_(\n'
           '    69                   exc_value,\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.util.langhelpers.safe_reraise object at 0x7f9e38ed0760>\n'
           '     type_ = None\n'
           '     value = None\n'
           '     traceback = None\n'
           "     exc_type = <class 'psycopg2.OperationalError'>\n"
           '     exc_value = OperationalError(\'connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\\n\\tIs the '
           'server\n'
           '                   running on that host and accepting TCP/IP connections?\\nconnection to server at "localhost" (::1), port 5432 failed: '
           'Ca\n'
           "                  nnot assign requested address\\n\\tIs the server running on that host and accepting TCP/IP connections?\\n')\n"
           '     exc_tb = <traceback object at 0x7f9e38ef0880>\n'
           '     self._exc_info = None\n'
           '     self.warn_only = False\n'
           "     compat.raise_ = <function 'raise_' compat.py:152>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    152  def raise_(\n'
           '    153      exception, with_traceback=None, replace_context=None, from_=False\n'
           '    154  ):\n'
           ' (...)\n'
           '    178          # that out.\n'
           '    179          exception.__cause__ = replace_context\n'
           '    180  \n'
           '    181      try:\n'
           '--> 182          raise exception\n'
           '    183      finally:\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 656, in '
           '__connect\n'
           '    648  def __connect(self, first_connect_check=False):\n'
           ' (...)\n'
           '    652      # creator fails, this attribute stays None\n'
           '    653      self.connection = None\n'
           '    654      try:\n'
           '    655          self.starttime = time.time()\n'
           '--> 656          connection = pool._invoke_creator(self)\n'
           '    657          pool.logger.debug("Created new connection %r", connection)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     first_connect_check = True\n'
           '     self.connection = None\n'
           '     self.starttime = 1655734285.144904\n'
           "     pool._invoke_creator = <function 'DefaultEngineStrategy.create.<locals>.connect' strategies.py:106>\n"
           "     pool.logger.debug = <method 'Logger.debug' of <Logger sqlalchemy.pool.impl.QueuePool (WARNING)> __init__.py:1424>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/strategies.py", line '
           '114, in connect\n'
           '    106  def connect(connection_record=None):\n'
           ' (...)\n'
           '    110                  dialect, connection_record, cargs, cparams\n'
           '    111              )\n'
           '    112              if connection is not None:\n'
           '    113                  return connection\n'
           '--> 114      return dialect.connect(*cargs, **cparams)\n'
           '    ..................................................\n'
           '     connection_record = <sqlalchemy.pool.base._ConnectionRecord object at 0x7f9e38ed0460>\n'
           '     dialect = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     cargs = []\n'
           "     cparams = {'host': 'localhost',\n"
           "                'database': 'analysis',\n"
           "                'user': 'postgres',\n"
           "                'password': 'tungdq_vng',\n"
           "                'port': 5432}\n"
           "     dialect.connect = <method 'DefaultDialect.connect' of <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at "
           '0x7f9e38f47fa0\n'
           '                        > default.py:506>\n'
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/default.py", line 508, '
           'in connect\n'
           '    506  def connect(self, *cargs, **cparams):\n'
           '    507      # inherits the docstring from interfaces.Dialect.connect\n'
           '--> 508      return self.dbapi.connect(*cargs, **cparams)\n'
           '    ..................................................\n'
           '     self = <sqlalchemy.dialects.postgresql.psycopg2.PGDialect_psycopg2 object at 0x7f9e38f47fa0>\n'
           '     cargs = ()\n'
           "     cparams = {'host': 'localhost',\n"
           "                'database': 'analysis',\n"
           "                'user': 'postgres',\n"
           "                'password': 'tungdq_vng',\n"
           "                'port': 5432}\n"
           "     self.dbapi.connect = <function 'connect' __init__.py:80>\n"
           '    ..................................................\n'
           '\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/psycopg2/__init__.py", line 122, in '
           'connect\n'
           '    80   def connect(dsn=None, connection_factory=None, cursor_factory=None, **kwargs):\n'
           ' (...)\n'
           "    118      if 'async_' in kwargs:\n"
           "    119          kwasync['async_'] = kwargs.pop('async_')\n"
           '    120  \n'
           '    121      dsn = _ext.make_dsn(dsn, **kwargs)\n'
           '--> 122      conn = _connect(dsn, connection_factory=connection_factory, **kwasync)\n'
           '    123      if cursor_factory is not None:\n'
           '    ..................................................\n'
           "     dsn = 'host=localhost user=postgres password=tungdq_vng port=5432 dbname=analysis'\n"
           '     connection_factory = None\n'
           '     cursor_factory = None\n'
           "     kwargs = {'host': 'localhost',\n"
           "               'database': 'analysis',\n"
           "               'user': 'postgres',\n"
           "               'password': 'tungdq_vng',\n"
           "               'port': 5432}\n"
           '     kwasync = {}\n'
           "     _ext.make_dsn = <function 'make_dsn' extensions.py:138>\n"
           '    ..................................................\n'
           '\n'
           '---- (full traceback above) ----\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/entrypoints.py", line 149, in '
           'main\n'
           '    sys.exit(datahub(standalone_mode=False, **kwargs))\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1130, in __call__\n'
           '    return self.main(*args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1055, in main\n'
           '    rv = self.invoke(ctx)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1657, in invoke\n'
           '    return _process_result(sub_ctx.command.invoke(sub_ctx))\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1657, in invoke\n'
           '    return _process_result(sub_ctx.command.invoke(sub_ctx))\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 1404, in invoke\n'
           '    return ctx.invoke(self.callback, **ctx.params)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/core.py", line 760, in invoke\n'
           '    return __callback(*args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/click/decorators.py", line 26, in '
           'new_func\n'
           '    return f(get_current_context(), *args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/upgrade/upgrade.py", line 333, '
           'in wrapper\n'
           '    res = func(*args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/telemetry/telemetry.py", line '
           '338, in wrapper\n'
           '    raise e\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/telemetry/telemetry.py", line '
           '290, in wrapper\n'
           '    res = func(*args, **kwargs)\n'
           'File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/utilities/memory_leak_detector.py", '
           'line 102, in wrapper\n'
           '    res = func(*args, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/cli/ingest_cli.py", line 131, in '
           'run\n'
           '    raise e\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/cli/ingest_cli.py", line 117, in '
           'run\n'
           '    pipeline.run()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/ingestion/run/pipeline.py", line '
           '213, in run\n'
           '    for wu in itertools.islice(\n'
           'File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/ingestion/source/sql/sql_common.py", '
           'line 710, in get_workunits\n'
           '    for inspector in self.get_inspectors():\n'
           'File '
           '"/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/ingestion/source/sql/sql_common.py", '
           'line 514, in get_inspectors\n'
           '    with engine.connect() as conn:\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2263, '
           'in connect\n'
           '    return self._connection_cls(self, **kwargs)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 104, in '
           '__init__\n'
           '    else engine.raw_connection()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2369, '
           'in raw_connection\n'
           '    return self._wrap_pool_connect(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2339, '
           'in _wrap_pool_connect\n'
           '    Connection._handle_dbapi_exception_noconnection(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 1583, '
           'in _handle_dbapi_exception_noconnection\n'
           '    util.raise_(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    raise exception\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/base.py", line 2336, '
           'in _wrap_pool_connect\n'
           '    return fn()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 304, in '
           'unique_connection\n'
           '    return _ConnectionFairy._checkout(self)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 778, in '
           '_checkout\n'
           '    fairy = _ConnectionRecord.checkout(pool)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 495, in '
           'checkout\n'
           '    rec = pool._do_get()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 140, in '
           '_do_get\n'
           '    self._dec_overflow()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    compat.raise_(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    raise exception\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/impl.py", line 137, in '
           '_do_get\n'
           '    return self._create_connection()\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 309, in '
           '_create_connection\n'
           '    return _ConnectionRecord(self)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 440, in '
           '__init__\n'
           '    self.__connect(first_connect_check=True)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 661, in '
           '__connect\n'
           '    pool.logger.debug("Error on connect(): %s", e)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line '
           '68, in __exit__\n'
           '    compat.raise_(\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 182, in '
           'raise_\n'
           '    raise exception\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/pool/base.py", line 656, in '
           '__connect\n'
           '    connection = pool._invoke_creator(self)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/strategies.py", line '
           '114, in connect\n'
           '    return dialect.connect(*cargs, **cparams)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/sqlalchemy/engine/default.py", line 508, '
           'in connect\n'
           '    return self.dbapi.connect(*cargs, **cparams)\n'
           'File "/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/psycopg2/__init__.py", line 122, in '
           'connect\n'
           '    conn = _connect(dsn, connection_factory=connection_factory, **kwasync)\n'
           '\n'
           'OperationalError: (psycopg2.OperationalError) connection to server at "localhost" (127.0.0.1), port 5432 failed: Connection refused\n'
           '\tIs the server running on that host and accepting TCP/IP connections?\n'
           'connection to server at "localhost" (::1), port 5432 failed: Cannot assign requested address\n'
           '\tIs the server running on that host and accepting TCP/IP connections?\n'
           '\n'
           '(Background on this error at: http://sqlalche.me/e/13/e3q8)\n'
           '[2022-06-20 14:11:25,909] INFO     {datahub.entrypoints:176} - DataHub CLI version: 0.8.38 at '
           '/tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/lib/python3.9/site-packages/datahub/__init__.py\n'
           '[2022-06-20 14:11:25,909] INFO     {datahub.entrypoints:179} - Python version: 3.9.9 (main, Dec 21 2021, 10:03:34) \n'
           '[GCC 10.2.1 20210110] at /tmp/datahub/ingest/venv-c8714baa-5356-494b-8268-4b3c987419b2/bin/python3 on '
           'Linux-5.13.0-51-generic-x86_64-with-glibc2.31\n'
           "[2022-06-20 14:11:25,909] INFO     {datahub.entrypoints:182} - GMS config {'models': {}, 'versions': {'linkedin/datahub': {'version': "
           "'v0.8.38', 'commit': '0ee2569d5c00b0f02312abdbd6c7f3ee7fe066b5'}}, 'managedIngestion': {'defaultCliVersion': '0.8.38', 'enabled': True}, "
           "'statefulIngestionCapable': True, 'supportsImpactAnalysis': True, 'telemetry': {'enabledCli': True, 'enabledIngestion': False}, "
           "'datasetUrnNameCasing': False, 'retention': 'true', 'datahub': {'serverType': 'quickstart'}, 'noCode': 'true'}\n",
           "2022-06-20 14:11:27.121238 [exec_id=c8714baa-5356-494b-8268-4b3c987419b2] INFO: Failed to execute 'datahub ingest'",
           '2022-06-20 14:11:27.121807 [exec_id=c8714baa-5356-494b-8268-4b3c987419b2] INFO: Caught exception EXECUTING '
           'task_id=c8714baa-5356-494b-8268-4b3c987419b2, name=RUN_INGEST, stacktrace=Traceback (most recent call last):\n'
           '  File "/usr/local/lib/python3.9/site-packages/acryl/executor/execution/default_executor.py", line 121, in execute_task\n'
           '    self.event_loop.run_until_complete(task_future)\n'
           '  File "/usr/local/lib/python3.9/site-packages/nest_asyncio.py", line 89, in run_until_complete\n'
           '    return f.result()\n'
           '  File "/usr/local/lib/python3.9/asyncio/futures.py", line 201, in result\n'
           '    raise self._exception\n'
           '  File "/usr/local/lib/python3.9/asyncio/tasks.py", line 256, in __step\n'
           '    result = coro.send(None)\n'
           '  File "/usr/local/lib/python3.9/site-packages/acryl/executor/execution/sub_process_ingestion_task.py", line 115, in execute\n'
           '    raise TaskError("Failed to execute \'datahub ingest\'")\n'
           "acryl.executor.execution.task.TaskError: Failed to execute 'datahub ingest'\n"]}
Execution finished with errors.