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