Datahub error log 2
unknown
plain_text
3 years ago
103 kB
3
Indexable
~~~~ 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.