Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- worker_1 | [2020-10-09 09:47:55,443] {{timeout.py:42}} ERROR - Process timed out, PID: 33
- worker_1 | Exception ignored in: <function _get_module_lock.<locals>.cb at 0x7f7be5fb63b0>
- worker_1 | Traceback (most recent call last):
- worker_1 | File "<frozen importlib._bootstrap>", line 177, in cb
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | [2020-10-09 09:47:55,561] {{timeout.py:42}} ERROR - Process timed out, PID: 40
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 33
- worker_1 | [2020-10-09 09:47:55,597] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 1, in <module>
- worker_1 | from google.cloud import storage
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/cloud/storage/__init__.py", line 40, in <module>
- worker_1 | from google.cloud.storage.bucket import Bucket
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/cloud/storage/bucket.py", line 26, in <module>
- worker_1 | from google.api_core import datetime_helpers
- worker_1 | File "<frozen importlib._bootstrap>", line 983, in _find_and_load
- worker_1 | File "<frozen importlib._bootstrap>", line 963, in _find_and_load_unlocked
- worker_1 | File "<frozen importlib._bootstrap>", line 906, in _find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1280, in find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1252, in _get_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1390, in find_spec
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 40
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | [2020-10-09 09:47:57,170] {{timeout.py:42}} ERROR - Process timed out, PID: 39
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- worker_1 | [2020-10-09 09:47:57,313] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "<frozen importlib._bootstrap_external>", line 87, in _path_is_mode_type
- worker_1 | File "<frozen importlib._bootstrap_external>", line 81, in _path_stat
- worker_1 | FileNotFoundError: [Errno 2] No such file or directory: '/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/__init__.cpython-37m-x86_64-linux-gnu.so'
- worker_1 |
- worker_1 | During handling of the above exception, another exception occurred:
- worker_1 |
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 3, in <module>
- worker_1 | import pandas as pd
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/__init__.py", line 50, in <module>
- worker_1 | import pandas.core.config_init
- worker_1 | File "<frozen importlib._bootstrap>", line 983, in _find_and_load
- worker_1 | File "<frozen importlib._bootstrap>", line 963, in _find_and_load_unlocked
- worker_1 | File "<frozen importlib._bootstrap>", line 906, in _find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1280, in find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1252, in _get_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1383, in find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 95, in _path_isfile
- worker_1 | File "<frozen importlib._bootstrap_external>", line 87, in _path_is_mode_type
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 39
- worker_1 | Traceback (most recent call last):
- worker_1 | [2020-10-09 09:47:57,512] {{timeout.py:42}} ERROR - Process timed out, PID: 43
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- worker_1 | [2020-10-09 09:47:57,882] {{timeout.py:42}} ERROR - Process timed out, PID: 41
- worker_1 | [2020-10-09 09:47:57,533] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 3, in <module>
- worker_1 | import pandas as pd
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/__init__.py", line 50, in <module>
- worker_1 | import pandas.core.config_init
- worker_1 | File "<frozen importlib._bootstrap>", line 983, in _find_and_load
- worker_1 | File "<frozen importlib._bootstrap>", line 967, in _find_and_load_unlocked
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 724, in exec_module
- worker_1 | File "<frozen importlib._bootstrap_external>", line 818, in get_code
- worker_1 | File "<frozen importlib._bootstrap_external>", line 916, in get_data
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 43
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- worker_1 | [2020-10-09 09:47:58,745] {{timeout.py:42}} ERROR - Process timed out, PID: 37
- worker_1 | [[2020-10-09 09:47:58,801] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 3, in <module>
- worker_1 | import pandas as pd
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/__init__.py", line 30, in <module>
- worker_1 | from pandas._libs import hashtable as _hashtable, lib as _lib, tslib as _tslib
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_libs/__init__.py", line 13, in <module>
- worker_1 | from pandas._libs.interval import Interval
- worker_1 | File "pandas/_libs/interval.pyx", line 1, in init pandas._libs.interval
- worker_1 | File "pandas/_libs/hashtable.pyx", line 1, in init pandas._libs.hashtable
- worker_1 | File "pandas/_libs/missing.pyx", line 1, in init pandas._libs.missing
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_libs/tslibs/__init__.py", line 30, in <module>
- worker_1 | from .conversion import OutOfBoundsTimedelta, localize_pydatetime
- worker_1 | File "pandas/_libs/tslibs/conversion.pyx", line 58, in init pandas._libs.tslibs.conversion
- worker_1 | File "pandas/_libs/tslibs/parsing.pyx", line 1, in init pandas._libs.tslibs.parsing
- worker_1 | File "pandas/_libs/tslibs/offsets.pyx", line 1, in init pandas._libs.tslibs.offsets
- worker_1 | File "pandas/_libs/tslibs/timestamps.pyx", line 47, in init pandas._libs.tslibs.timestamps
- worker_1 | File "pandas/_libs/tslibs/fields.pyx", line 16, in init pandas._libs.tslibs.fields
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_config/localization.py", line 6, in <module>
- worker_1 | from contextlib import contextmanager
- worker_1 | File "<frozen importlib._bootstrap>", line 1009, in _handle_fromlist
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 37
- worker_1 | 2020-10-09 09:47:59,174] {{timeout.py:42}} ERROR - Process timed out, PID: 36
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- worker_1 | [2020-10-09 09:47:59,308] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 1, in <module>
- worker_1 | from google.cloud import storage
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/cloud/storage/__init__.py", line 38, in <module>
- worker_1 | from google.cloud.storage.batch import Batch
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/cloud/storage/batch.py", line 31, in <module>
- worker_1 | from google.cloud.storage._http import Connection
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/cloud/storage/_http.py", line 17, in <module>
- worker_1 | from google.cloud import _http
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/cloud/_http.py", line 25, in <module>
- worker_1 | from google.api_core.client_info import ClientInfo
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/google/api_core/client_info.py", line 31, in <module>
- worker_1 | _GRPC_VERSION = pkg_resources.get_distribution("grpcio").version
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 465, in get_distribution
- worker_1 | dist = get_provider(dist)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 341, in get_provider
- worker_1 | return working_set.find(moduleOrReq) or require(str(moduleOrReq))[0]
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 884, in require
- worker_1 | needed = self.resolve(parse_requirements(requirements))
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 757, in resolve
- worker_1 | env = Environment(self.entries)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 968, in __init__
- worker_1 | self.scan(search_path)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 1000, in scan
- worker_1 | for dist in find_distributions(item):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 2060, in find_on_path
- worker_1 | for dist in factory(fullpath):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/pkg_resources/__init__.py", line 2124, in distributions_from_metadata
- worker_1 | entry = os.path.basename(path)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 36
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- worker_1 | [2020-10-09 09:48:02,471] {{timeout.py:42}} ERROR - Process timed out, PID: 35
- worker_1 | [2020-10-09 09:48:02,523] {{timeout.py:42}} ERROR - Process timed out, PID: 42
- worker_1 | [2020-10-09 09:48:02,603] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 3, in <module>
- worker_1 | import pandas as pd
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/__init__.py", line 30, in <module>
- worker_1 | from pandas._libs import hashtable as _hashtable, lib as _lib, tslib as _tslib
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_libs/__init__.py", line 13, in <module>
- worker_1 | from pandas._libs.interval import Interval
- worker_1 | File "pandas/_libs/interval.pyx", line 1, in init pandas._libs.interval
- worker_1 | File "pandas/_libs/hashtable.pyx", line 1, in init pandas._libs.hashtable
- worker_1 | File "pandas/_libs/missing.pyx", line 1, in init pandas._libs.missing
- worker_1 | File "<frozen importlib._bootstrap>", line 978, in _find_and_load
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 42
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | [2020-10-09 09:48:02,548] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 3, in <module>
- worker_1 | import pandas as pd
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/__init__.py", line 30, in <module>
- worker_1 | from pandas._libs import hashtable as _hashtable, lib as _lib, tslib as _tslib
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_libs/__init__.py", line 13, in <module>
- worker_1 | from pandas._libs.interval import Interval
- worker_1 | File "pandas/_libs/interval.pyx", line 1, in init pandas._libs.interval
- worker_1 | File "pandas/_libs/hashtable.pyx", line 1, in init pandas._libs.hashtable
- worker_1 | File "pandas/_libs/missing.pyx", line 1, in init pandas._libs.missing
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_libs/tslibs/__init__.py", line 35, in <module>
- worker_1 | from .period import IncompatibleFrequency, Period
- worker_1 | File "pandas/_libs/tslibs/period.pyx", line 1, in init pandas._libs.tslibs.period
- worker_1 | File "<frozen importlib._bootstrap>", line 194, in _lock_unlock_module
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 35
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | dag = get_dag(args)
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- scheduler_1 | [2020-10-09 09:48:09,613] {{scheduler_job.py:951}} INFO - 60 tasks up for execution:
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-24 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-10-02 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-21 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-25 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-29 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.nopowerup.idlelightcity 2020-09-21 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.nopowerup.idlelightcity 2020-09-25 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.nopowerup.idlelightcity 2020-09-29 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.nopowerup.idlelightcity 2020-10-02 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.playquantum.battler 2020-09-21 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.playquantum.battler 2020-09-22 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.playquantum.battler 2020-09-24 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.playquantum.battler 2020-09-25 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.playquantum.battler 2020-09-26 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-22 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-26 04:05:00+00:00 [scheduled]>
- scheduler_1 | <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-09-30 04:05:00+00:00 [scheduled]>
- scheduler_1 | [2020-10-09 09:50:03,480] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,481] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.rmg.hotelteam 2020-10-01 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,504] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,504] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.rmg.idle.evil.party.clicker 2020-10-01 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,505] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,531] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.evilclicker.evilclicker 2020-10-02 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,532] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,532] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.nopowerup.idlelightcity 2020-10-02 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,532] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,577] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.playquantum.battler 2020-10-02 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,577] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,589] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.rmg.hotelteam 2020-10-02 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,589] {{scheduler_job.py:1010}} INFO - DAG test_google_dag has 16/16 running and queued tasks
- scheduler_1 | [2020-10-09 09:50:03,590] {{scheduler_job.py:1016}} INFO - Not executing <TaskInstance: test_google_dag.com.rmg.idle.evil.party.clicker 2020-10-02 04:05:00+00:00 [scheduled]> since the number of tasks running or queued from DAG test_google_dag is >= to the DAG's task concurrency limit of 16
- scheduler_1 | [2020-10-09 09:50:03,643] {{scheduler_job.py:1060}} INFO - Setting the following tasks to queued state:
- scheduler_1 |
- worker_1 | [2020-10-09 09:50:08,815: WARNING/MainProcess] process with pid=130 already exited
- worker_1 | [2020-10-09 09:50:08,961] {{timeout.py:42}} ERROR - Process timed out, PID: 77
- worker_1 | [2020-10-09 09:50:09,713: ERROR/MainProcess] Timed out waiting for UP message from <ForkProcess(ForkPoolWorker-40, started daemon)>
- worker_1 | [2020-10-09 09:50:09,907: ERROR/MainProcess] Timed out waiting for UP message from <ForkProcess(ForkPoolWorker-41, started daemon)>
- worker_1 | [2020-10-09 09:50:09,972: INFO/MainProcess] Received task: airflow.executors.celery_executor.execute_command[39745152-098d-471f-b918-2a4d1773be3e]
- worker_1 | [2020-10-09 09:50:10,483: INFO/ForkPoolWorker-4] Executing command in Celery: ['airflow', 'run', 'test_google_dag', 'com.rmg.hotelteam', '2020-09-18T04:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/dag_google_api.py']
- worker_1 | [2020-10-09 09:50:10,483: INFO/ForkPoolWorker-8] Executing command in Celery: ['airflow', 'run', 'test_google_dag', 'com.rmg.hotelteam', '2020-09-17T04:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/dag_google_api.py']
- worker_1 | [2020-10-09 09:50:10,527: INFO/MainProcess] Received task: airflow.executors.celery_executor.execute_command[5c25f47a-9d15-4674-b1c7-5c94c7be2362]
- worker_1 | [2020-10-09 09:50:09,041] {{dagbag.py:239}} ERROR - Failed to import: /usr/local/airflow/dags/dag_google_api.py
- worker_1 | Traceback (most recent call last):
- worker_1 | File "<frozen importlib._bootstrap_external>", line 87, in _path_is_mode_type
- worker_1 | File "<frozen importlib._bootstrap_external>", line 81, in _path_stat
- worker_1 | FileNotFoundError: [Errno 2] No such file or directory: '/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/_libs/window/__init__.cpython-37m-x86_64-linux-gnu.so'
- worker_1 |
- worker_1 | During handling of the above exception, another exception occurred:
- worker_1 |
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line 236, in process_file
- worker_1 | m = imp.load_source(mod_name, filepath)
- worker_1 | File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
- worker_1 | module = _load(spec)
- worker_1 | File "<frozen importlib._bootstrap>", line 696, in _load
- worker_1 | File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
- worker_1 | File "<frozen importlib._bootstrap_external>", line 728, in exec_module
- worker_1 | File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
- worker_1 | File "/usr/local/airflow/dags/dag_google_api.py", line 3, in <module>
- worker_1 | from scripts.common.google_api2 import Google_console_api
- worker_1 | File "/usr/local/airflow/dags/scripts/common/google_api2.py", line 3, in <module>
- worker_1 | import pandas as pd
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/__init__.py", line 52, in <module>
- worker_1 | from pandas.core.api import (
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/api.py", line 29, in <module>
- worker_1 | from pandas.core.groupby import Grouper, NamedAgg
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/groupby/__init__.py", line 1, in <module>
- worker_1 | from pandas.core.groupby.generic import DataFrameGroupBy, NamedAgg, SeriesGroupBy
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/groupby/generic.py", line 57, in <module>
- worker_1 | from pandas.core.aggregation import (
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/aggregation.py", line 27, in <module>
- worker_1 | from pandas.core.series import FrameOrSeriesUnion, Series
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/series.py", line 4983, in <module>
- worker_1 | Series._add_series_or_dataframe_operations()
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/generic.py", line 10511, in _add_series_or_dataframe_operations
- worker_1 | from pandas.core.window import (
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/window/__init__.py", line 1, in <module>
- worker_1 | from pandas.core.window.ewm import ExponentialMovingWindow # noqa:F401
- worker_1 | File "/usr/local/airflow/.local/lib/python3.7/site-packages/pandas/core/window/ewm.py", line 9, in <module>
- worker_1 | import pandas._libs.window.aggregations as window_aggregations
- worker_1 | File "<frozen importlib._bootstrap>", line 983, in _find_and_load
- worker_1 | File "<frozen importlib._bootstrap>", line 963, in _find_and_load_unlocked
- worker_1 | File "<frozen importlib._bootstrap>", line 906, in _find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1280, in find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1252, in _get_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 1383, in find_spec
- worker_1 | File "<frozen importlib._bootstrap_external>", line 95, in _path_isfile
- worker_1 | File "<frozen importlib._bootstrap_external>", line 87, in _path_is_mode_type
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/timeout.py", line 43, in handle_timeout
- worker_1 | raise AirflowTaskTimeout(self.error_message)
- worker_1 | airflow.exceptions.AirflowTaskTimeout: Timeout, PID: 77
- worker_1 | Traceback (most recent call last):
- worker_1 | File "/usr/local/bin/airflow", line 37, in <module>
- worker_1 | args.func(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 75, in wrapper
- worker_1 | [2020-10-09 09:50:11,446: INFO/MainProcess] Received task: airflow.executors.celery_executor.execute_command[d91fac0f-0e08-4a49-a08b-ed1f6cc89a3a]
- worker_1 | [2020-10-09 09:50:11,466: INFO/MainProcess] Scaling up 1 processes.
- worker_1 | return f(*args, **kwargs)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 523, in run
- worker_1 | [2020-10-09 09:50:11,515: ERROR/MainProcess] Process 'ForkPoolWorker-41' pid:146 exited with 'signal 9 (SIGKILL)'
- worker_1 | dag = get_dag(args)
- worker_1 | File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 149, in get_dag
- worker_1 | [2020-10-09 09:50:11,567: ERROR/MainProcess] Process 'ForkPoolWorker-40' pid:141 exited with 'signal 9 (SIGKILL)'
- worker_1 | 'parse.'.format(args.dag_id))
- worker_1 | airflow.exceptions.AirflowException: dag_id could not be found: test_google_dag. Either the dag did not exist or it failed to parse.
- postgres_1 | WARNING: could not open statistics file "pg_stat_tmp/global.stat": Operation not permitted
- webserver_1 | ____________ _____________
- webserver_1 | ____ |__( )_________ __/__ /________ __
- webserver_1 | ____ /| |_ /__ ___/_ /_ __ /_ __ \_ | /| / /
- webserver_1 | ___ ___ | / _ / _ __/ _ / / /_/ /_ |/ |/ /
- webserver_1 | _/_/ |_/_/ /_/ /_/ /_/ \____/____/|__/
- webserver_1 | [2020-10-09 09:50:17,819] {{__init__.py:51}} INFO - Using executor CeleryExecutor
- webserver_1 | [2020-10-09 09:50:17,825] {{dagbag.py:396}} INFO - Filling up the DagBag from /usr/local/airflow/dags
- scheduler_1 | [2020-10-09 09:50:17,912] {{scheduler_job.py:951}} INFO - 58 tasks up for execution:
Add Comment
Please, Sign In to add comment