Meltano ELT fails when running on native windows
(needs the Windows Support tag)
To replicate on windows
PS C:\code\meltano-windowstest2> meltano --version
meltano, version 1.73.0
PS C:\code\meltano-windowstest2> $Env:PYTHONASYNCIODEBUG=1
PS C:\code\meltano-windowstest2> meltano --log-level=debug elt tap-csv target-csvOutput from Meltano command (Note that the data in this instance actually does properly flow to my output file, but the program is stuck and I have to signal the process (CTRL+C) to stop the program, which then leads to the exceptions being dumped. Also note that I tried to dump the output to a log file instead of my command prompt output but that didn't include the exception information from asyncio (>log 2>&1) after the CTRL+C was sent so this is just a straight copy from my powershell window instead.
The exceptions not being printed is probably caused by loop.set_exception_handler not being utilized. That could probably be a separate issue, and would help some folks with debugging asyncio. I only stumbled on this because I mess up code all the time and was upset I couldn't see RunTime Exceptions.
Output from a "successful" run
PS C:\code\meltano-windowstest2> meltano --version
meltano, version 1.73.0
PS C:\code\meltano-windowstest2> $Env:PYTHONASYNCIODEBUG=1
PS C:\code\meltano-windowstest2> meltano --log-level=debug elt tap-csv target-csv
[2021-05-05 14:12:21,076] [12024|MainThread|root] [DEBUG] Creating engine <meltano.core.project.Project object at 0x000001A94C457970>@sqlite:///C:\code\meltano-windowstest2/.meltano/meltano.db
[2021-05-05 14:12:21,110] [12024|MainThread|asyncio] [DEBUG] Using proactor: IocpProactor
meltano | DEBUG Starting new HTTPS connection (1): www.meltano.com:443
meltano | DEBUG https://www.meltano.com:443 "GET /discovery.yml?project_id=1281de93-235e-4185-85ce-2b3555a991ae HTTP/1.1" 200 103053
meltano | DEBUG Variable '$MELTANO_LOAD_SCHEMA' is missing from the environment.
meltano | INFO Running extract & load...
meltano | DEBUG Created configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T181221--tap-csv--target-csv\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\tap.config.json
meltano | DEBUG Could not find tap.properties.json in C:\code\meltano-windowstest2\.meltano\extractors\tap-csv\tap.properties.json, skipping.
meltano | DEBUG Could not find tap.properties.cache_key in C:\code\meltano-windowstest2\.meltano\extractors\tap-csv\tap.properties.cache_key, skipping.
meltano | DEBUG Could not find state.json in C:\code\meltano-windowstest2\.meltano\extractors\tap-csv\state.json, skipping.
meltano | DEBUG Variable '$MELTANO_LOAD_SCHEMA' is missing from the environment.
meltano | DEBUG Variable '$MELTANO_LOAD_SCHEMA' is missing from the environment.
meltano | DEBUG Created configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T181221--tap-csv--target-csv\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\target.config.json
meltano | WARNING No state was found, complete import.
meltano | DEBUG Invoking: ['C:\\code\\meltano-windowstest2\\.meltano\\extractors\\tap-csv\\venv\\Scripts\\tap-csv', '--config', 'C:\\code\\meltano-windowstest2\\.meltano\\run\\elt\\2021-05-05T181221--tap-csv--target-csv\\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\\tap.config.json', '--discover']
meltano | DEBUG Env: REDACTED
meltano | WARNING A catalog file was found, but it will be ignored as the extractor does not advertise the `catalog` or `properties` capability
meltano | DEBUG Invoking: ['C:\\code\\meltano-windowstest2\\.meltano\\extractors\\tap-csv\\venv\\Scripts\\tap-csv', '--config', 'C:\\code\\meltano-windowstest2\\.meltano\\run\\elt\\2021-05-05T181221--tap-csv--target-csv\\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\\tap.config.json']
meltano | DEBUG Env: REDACTED
meltano | DEBUG execute program 'C:\\code\\meltano-windowstest2\\.meltano\\extractors\\tap-csv\\venv\\Scripts\\tap-csv' stdout=<pipe> stderr=<pipe>
meltano | DEBUG process 'C:\\code\\meltano-windowstest2\\.meltano\\extractors\\tap-csv\\venv\\Scripts\\tap-csv' created: pid 7140
meltano | WARNING Executing <Task pending name='Task-1' coro=<_run_job() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py:214> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9533305E0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> cb=[_run_until_complete_cb() at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:184] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py:37> took 0.969 seconds
meltano | DEBUG <_ProactorReadPipeTransport fd=4>: Fatal read error on pipe transport
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
meltano | ERROR Exception in callback _ProactorReadPipeTransport._loop_reading()
handle: <Handle _ProactorReadPipeTransport._loop_reading() created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py:187>
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 201, in _read_from_fd
read_transport, _ = await loop.connect_read_pipe(
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1525, in connect_read_pipe
transport = self._make_read_pipe_transport(pipe, protocol, waiter)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 664, in _make_read_pipe_transport
return _ProactorReadPipeTransport(self, sock, protocol, waiter, extra)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 187, in __init__
self._loop.call_soon(self._loop_reading)
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 309, in _loop_reading
self._fatal_error(exc, 'Fatal read error on pipe transport')
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 131, in _fatal_error
self._force_close(exc)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 134, in _force_close
if self._empty_waiter is not None and not self._empty_waiter.done():
AttributeError: '_ProactorReadPipeTransport' object has no attribute '_empty_waiter'
meltano | DEBUG <_ProactorReadPipeTransport fd=6>: Fatal read error on pipe transport
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
meltano | ERROR Exception in callback _ProactorReadPipeTransport._loop_reading()
handle: <Handle _ProactorReadPipeTransport._loop_reading() created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py:187>
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 201, in _read_from_fd
read_transport, _ = await loop.connect_read_pipe(
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1525, in connect_read_pipe
transport = self._make_read_pipe_transport(pipe, protocol, waiter)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 664, in _make_read_pipe_transport
return _ProactorReadPipeTransport(self, sock, protocol, waiter, extra)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 187, in __init__
self._loop.call_soon(self._loop_reading)
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 309, in _loop_reading
self._fatal_error(exc, 'Fatal read error on pipe transport')
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 131, in _fatal_error
self._force_close(exc)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 134, in _force_close
if self._empty_waiter is not None and not self._empty_waiter.done():
AttributeError: '_ProactorReadPipeTransport' object has no attribute '_empty_waiter'
meltano | DEBUG Read pipe 4 connected: (<_ProactorReadPipeTransport fd=4>, <asyncio.streams.StreamReaderProtocol object at 0x000001A9530B7B20>)
meltano | DEBUG Read pipe 6 connected: (<_ProactorReadPipeTransport fd=6>, <asyncio.streams.StreamReaderProtocol object at 0x000001A9530B7CD0>)
meltano | DEBUG Read pipe 836 connected: (<_ProactorReadPipeTransport fd=836 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953203dc0> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>, <ReadSubprocessPipeProto fd=1 pipe=<_ProactorReadPipeTransport fd=836 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953203dc0> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>)
meltano | DEBUG Read pipe 876 connected: (<_ProactorReadPipeTransport fd=876 read=<_OverlappedFuture pending overlapped=<pending, 0x1a9531180d0> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>, <ReadSubprocessPipeProto fd=2 pipe=<_ProactorReadPipeTransport fd=876 read=<_OverlappedFuture pending overlapped=<pending, 0x1a9531180d0> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>)
meltano | INFO execute program 'C:\\code\\meltano-windowstest2\\.meltano\\extractors\\tap-csv\\venv\\Scripts\\tap-csv': <_WindowsSubprocessTransport pid=7140 running stdout=<_ProactorReadPipeTransport fd=836 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953203dc0> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>> stderr=<_ProactorReadPipeTransport fd=876 read=<_OverlappedFuture pending overlapped=<pending, 0x1a9531180d0> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>
meltano | DEBUG Invoking: ['C:\\code\\meltano-windowstest2\\.meltano\\loaders\\target-csv\\venv\\Scripts\\target-csv', '--config', 'C:\\code\\meltano-windowstest2\\.meltano\\run\\elt\\2021-05-05T181221--tap-csv--target-csv\\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\\target.config.json']
meltano | DEBUG Env: REDACTED
meltano | DEBUG execute program 'C:\\code\\meltano-windowstest2\\.meltano\\loaders\\target-csv\\venv\\Scripts\\target-csv' stdin=<pipe> stdout=<pipe> stderr=<pipe>
meltano | DEBUG process 'C:\\code\\meltano-windowstest2\\.meltano\\loaders\\target-csv\\venv\\Scripts\\target-csv' created: pid 18608
meltano | DEBUG Write pipe 904 connected: (<_ProactorWritePipeTransport fd=904 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375430> cb=[_ProactorWritePipeTransport._pipe_closed()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>, <WriteSubprocessPipeProto fd=0 pipe=<_ProactorWritePipeTransport fd=904 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375430> cb=[_ProactorWritePipeTransport._pipe_closed()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>)
meltano | DEBUG Read pipe 968 connected: (<_ProactorReadPipeTransport fd=968 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375550> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>, <ReadSubprocessPipeProto fd=1 pipe=<_ProactorReadPipeTransport fd=968 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375550> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>)
meltano | DEBUG Read pipe 920 connected: (<_ProactorReadPipeTransport fd=920 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375670> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>, <ReadSubprocessPipeProto fd=2 pipe=<_ProactorReadPipeTransport fd=920 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375670> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>)
meltano | INFO execute program 'C:\\code\\meltano-windowstest2\\.meltano\\loaders\\target-csv\\venv\\Scripts\\target-csv': <_WindowsSubprocessTransport pid=18608 running stdin=<_ProactorWritePipeTransport fd=904 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375430> cb=[_ProactorWritePipeTransport._pipe_closed()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>> stdout=<_ProactorReadPipeTransport fd=968 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375550> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>> stderr=<_ProactorReadPipeTransport fd=920 read=<_OverlappedFuture pending overlapped=<pending, 0x1a953375670> cb=[_ProactorReadPipeTransport._loop_reading()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py:465>>>
tap-csv | INFO Starting sync
tap-csv | INFO Syncing entity 'things' from file: 'input.csv'
tap-csv (out) | {"type": "SCHEMA", "stream": "things", "schema": {"type": "object", "properties": {"id": {"type": "string"}, " name": {"type": "string"}}}, "key_properties": ["id"]}
tap-csv (out) | {"type": "RECORD", "stream": "things", "record": {"id": "1", " name": " Derek"}}
tap-csv (out) | {"type": "RECORD", "stream": "things", "record": {"id": "2", " name": " Cener"}}
tap-csv (out) | {"type": "STATE", "value": {}}
tap-csv | INFO Sync completed
meltano | DEBUG <_ProactorReadPipeTransport fd=876> received EOF
meltano | DEBUG <_ProactorReadPipeTransport fd=836> received EOF
meltano | INFO <_WindowsSubprocessTransport pid=7140 running stdout=<_ProactorReadPipeTransport closing fd=836> stderr=<_ProactorReadPipeTransport closing fd=876>> exited with return code 0
target-csv | INFO Sending version information to singer.io. To disable sending anonymous usage data, set the config parameter "disable_collection" to true
target-csv (out) | {}
meltano | INFO Incremental state has been updated at 2021-05-05 18:12:22.353325.
meltano | DEBUG Incremental state: {}
meltano | DEBUG <_ProactorReadPipeTransport fd=968> received EOF
meltano | DEBUG <_ProactorReadPipeTransport fd=920> received EOF
meltano | INFO <_WindowsSubprocessTransport pid=18608 running stdin=<_ProactorWritePipeTransport closed> stdout=<_ProactorReadPipeTransport closing fd=968> stderr=<_ProactorReadPipeTransport closing fd=920>> exited with return code 0
meltano | DEBUG Deleted configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T181221--tap-csv--target-csv\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\target.config.json
meltano | DEBUG Deleted configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T181221--tap-csv--target-csv\1aec1d92-7fb9-4e86-885f-f71ddf7f6db1\tap.config.json
meltano | INFO Extract & load complete!
meltano | INFO Transformation skipped.
Aborted!
Exception ignored in: <coroutine object _run_job at 0x000001A9530120C0>
RuntimeError: coroutine ignored GeneratorExit
meltano | ERROR Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 194, in _run_module_as_main
return _run_code(code, main_globals, None,
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 87, in _run_code
exec(code, run_globals)
File "C:\Users\derek\AppData\Local\Programs\Python\Python38\Scripts\meltano.exe\__main__.py", line 7, in <module>
sys.exit(main())
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\__init__.py", line 43, in main
cli(obj={"project": None})
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 782, in main
rv = self.invoke(ctx)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 610, in invoke
return callback(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 23, in decorate
return func(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 57, in decorate
func(project, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 137, in elt
run_async(_run_job(project, job, session, context_builder, force=force))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py", line 37, in run_async
future = asyncio.ensure_future(coro)
task: <Task pending name='Task-1' coro=<_run_job() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py:214> wait_for=<Task pending name='Task-4' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9530B7CA0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001A953330040>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148> created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py:37>
--- Logging error ---
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\logging\__init__.py", line 1084, in emit
stream.write(msg + self.terminator)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 65, in write
self.__out.writeline(line)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 174, in writeline
click.echo(self.prefix + line, nl=False, file=self)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\utils.py", line 272, in echo
file.write(message)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\_compat.py", line 710, in _safe_write
return _write(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 41, in write
self.__convertor.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 164, in write
self.wrapped.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 179, in write
self.file.write(remove_ansi_escape_sequences(data))
ValueError: I/O operation on closed file.
Call stack:
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1733, in call_exception_handler
self.default_exception_handler(context)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1707, in default_exception_handler
logger.error('\n'.join(log_lines), exc_info=exc_info)
Message: 'Task was destroyed but it is pending!\nsource_traceback: Object created at (most recent call last):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 194, in _run_module_as_main\n return _run_code(code, main_globals, None,\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 87, in _run_code\n exec(code, run_globals)\n File "C:\\Users\\derek\\AppData\\Local\\Programs\\Python\\Python38\\Scripts\\meltano.exe\\__main__.py", line 7, in <module>\n sys.exit(main())\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\__init__.py", line 43, in main\n cli(obj={"project": None})\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 829, in __call__\n return self.main(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 782, in main\n rv = self.invoke(ctx)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1259, in invoke\n return _process_result(sub_ctx.command.invoke(sub_ctx))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1066, in invoke\n return ctx.invoke(self.callback, **ctx.params)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 610, in invoke\n return callback(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 23, in decorate\n return func(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 57, in decorate\n func(project, *args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 137, in elt\n run_async(_run_job(project, job, session, context_builder, force=force))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py", line 37, in run_async\n future = asyncio.ensure_future(coro)\ntask: <Task pending name=\'Task-1\' coro=<_run_job() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py:214> wait_for=<Task pending name=\'Task-4\' coro=<Out._read_from_fd() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9530B7CA0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001A953330040>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:148> created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py:37>'
Arguments: ()
Exception ignored in: <generator object Job._handling_sigterm at 0x000001A953096AC0>
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\job\job.py", line 229, in _handling_sigterm
signal.signal(signal.SIGTERM, original_termination_handler)
File "c:\users\derek\appdata\local\programs\python\python38\lib\signal.py", line 47, in signal
handler = _signal.signal(_enum_to_int(signalnum), _enum_to_int(handler))
TypeError: signal handler must be signal.SIG_IGN, signal.SIG_DFL, or a callable object
meltano | ERROR Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 194, in _run_module_as_main
return _run_code(code, main_globals, None,
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 87, in _run_code
exec(code, run_globals)
File "C:\Users\derek\AppData\Local\Programs\Python\Python38\Scripts\meltano.exe\__main__.py", line 7, in <module>
sys.exit(main())
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\__init__.py", line 43, in main
cli(obj={"project": None})
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 782, in main
rv = self.invoke(ctx)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 610, in invoke
return callback(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 23, in decorate
return func(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 57, in decorate
func(project, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 137, in elt
run_async(_run_job(project, job, session, context_builder, force=force))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py", line 39, in run_async
loop.run_until_complete(future)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 603, in run_until_complete
self.run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 214, in _run_job
await _run_elt(project, context_builder, output_logger)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 232, in _run_elt
async with _redirect_output(output_logger):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 223, in _redirect_output
async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 161, in redirect_stdout
async with self.writer() as stdout:
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 148, in writer
reader = asyncio.ensure_future(self._read_from_fd(read_fd))
task: <Task pending name='Task-3' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9531164F0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148>
--- Logging error ---
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\logging\__init__.py", line 1084, in emit
stream.write(msg + self.terminator)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 65, in write
self.__out.writeline(line)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 174, in writeline
click.echo(self.prefix + line, nl=False, file=self)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\utils.py", line 272, in echo
file.write(message)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\_compat.py", line 710, in _safe_write
return _write(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 41, in write
self.__convertor.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 164, in write
self.wrapped.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 179, in write
self.file.write(remove_ansi_escape_sequences(data))
ValueError: I/O operation on closed file.
Call stack:
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1733, in call_exception_handler
self.default_exception_handler(context)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1707, in default_exception_handler
logger.error('\n'.join(log_lines), exc_info=exc_info)
Message: 'Task was destroyed but it is pending!\nsource_traceback: Object created at (most recent call last):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 194, in _run_module_as_main\n return _run_code(code, main_globals, None,\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 87, in _run_code\n exec(code, run_globals)\n File "C:\\Users\\derek\\AppData\\Local\\Programs\\Python\\Python38\\Scripts\\meltano.exe\\__main__.py", line 7, in <module>\n sys.exit(main())\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\__init__.py", line 43, in main\n cli(obj={"project": None})\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 829, in __call__\n return self.main(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 782, in main\n rv = self.invoke(ctx)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1259, in invoke\n return _process_result(sub_ctx.command.invoke(sub_ctx))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1066, in invoke\n return ctx.invoke(self.callback, **ctx.params)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 610, in invoke\n return callback(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 23, in decorate\n return func(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 57, in decorate\n func(project, *args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 137, in elt\n run_async(_run_job(project, job, session, context_builder, force=force))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py", line 39, in run_async\n loop.run_until_complete(future)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 603, in run_until_complete\n self.run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\windows_events.py", line 316, in run_forever\n super().run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 570, in run_forever\n self._run_once()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 1851, in _run_once\n handle._run()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\events.py", line 81, in _run\n self._context.run(self._callback, *self._args)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 214, in _run_job\n await _run_elt(project, context_builder, output_logger)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 232, in _run_elt\n async with _redirect_output(output_logger):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 223, in _redirect_output\n async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 161, in redirect_stdout\n async with self.writer() as stdout:\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 148, in writer\n reader = asyncio.ensure_future(self._read_from_fd(read_fd))\ntask: <Task pending name=\'Task-3\' coro=<Out._read_from_fd() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9531164F0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py:422> created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:148>'
Arguments: ()
meltano | ERROR Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 194, in _run_module_as_main
return _run_code(code, main_globals, None,
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 87, in _run_code
exec(code, run_globals)
File "C:\Users\derek\AppData\Local\Programs\Python\Python38\Scripts\meltano.exe\__main__.py", line 7, in <module>
sys.exit(main())
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\__init__.py", line 43, in main
cli(obj={"project": None})
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 782, in main
rv = self.invoke(ctx)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 610, in invoke
return callback(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 23, in decorate
return func(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 57, in decorate
func(project, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 137, in elt
run_async(_run_job(project, job, session, context_builder, force=force))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py", line 39, in run_async
loop.run_until_complete(future)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 603, in run_until_complete
self.run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 214, in _run_job
await _run_elt(project, context_builder, output_logger)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 232, in _run_elt
async with _redirect_output(output_logger):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 223, in _redirect_output
async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 167, in redirect_stderr
async with self.writer() as stderr:
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 148, in writer
reader = asyncio.ensure_future(self._read_from_fd(read_fd))
task: <Task pending name='Task-4' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9530B7CA0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001A953330040>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148>
--- Logging error ---
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\logging\__init__.py", line 1084, in emit
stream.write(msg + self.terminator)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 65, in write
self.__out.writeline(line)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 174, in writeline
click.echo(self.prefix + line, nl=False, file=self)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\utils.py", line 272, in echo
file.write(message)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\_compat.py", line 710, in _safe_write
return _write(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 41, in write
self.__convertor.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 164, in write
self.wrapped.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 179, in write
self.file.write(remove_ansi_escape_sequences(data))
ValueError: I/O operation on closed file.
Call stack:
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1733, in call_exception_handler
self.default_exception_handler(context)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1707, in default_exception_handler
logger.error('\n'.join(log_lines), exc_info=exc_info)
Message: 'Task was destroyed but it is pending!\nsource_traceback: Object created at (most recent call last):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 194, in _run_module_as_main\n return _run_code(code, main_globals, None,\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 87, in _run_code\n exec(code, run_globals)\n File "C:\\Users\\derek\\AppData\\Local\\Programs\\Python\\Python38\\Scripts\\meltano.exe\\__main__.py", line 7, in <module>\n sys.exit(main())\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\__init__.py", line 43, in main\n cli(obj={"project": None})\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 829, in __call__\n return self.main(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 782, in main\n rv = self.invoke(ctx)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1259, in invoke\n return _process_result(sub_ctx.command.invoke(sub_ctx))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1066, in invoke\n return ctx.invoke(self.callback, **ctx.params)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 610, in invoke\n return callback(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 23, in decorate\n return func(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 57, in decorate\n func(project, *args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 137, in elt\n run_async(_run_job(project, job, session, context_builder, force=force))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py", line 39, in run_async\n loop.run_until_complete(future)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 603, in run_until_complete\n self.run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\windows_events.py", line 316, in run_forever\n super().run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 570, in run_forever\n self._run_once()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 1851, in _run_once\n handle._run()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\events.py", line 81, in _run\n self._context.run(self._callback, *self._args)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 214, in _run_job\n await _run_elt(project, context_builder, output_logger)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 232, in _run_elt\n async with _redirect_output(output_logger):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 223, in _redirect_output\n async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 167, in redirect_stderr\n async with self.writer() as stderr:\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 148, in writer\n reader = asyncio.ensure_future(self._read_from_fd(read_fd))\ntask: <Task pending name=\'Task-4\' coro=<Out._read_from_fd() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001A9530B7CA0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001A953330040>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:148>'
Arguments: ()
Exception ignored in: <coroutine object _AsyncGeneratorContextManager.__aexit__ at 0x000001A953180AC0>
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 84, in __aexit__
raise
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 14, in __aexit__
await self._aiter.aclose()
RuntimeError: aclose(): asynchronous generator is already running
Exception ignored in: <coroutine object _AsyncGeneratorContextManager.__aexit__ at 0x000001A953180DC0>
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 84, in __aexit__
raise
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 14, in __aexit__
await self._aiter.aclose()
RuntimeError: aclose(): asynchronous generator is already runningOutput of the same command with a problem reading my catalog file (ignore the catalog errors, and you'll see the asyncio issues). When there's an issue in the tap asyncio tends to blow up on you with the waiter issue being brought up. Maybe there's something to do with the handling of a tap failure?
PS C:\code\meltano-windowstest2> meltano --log-level=debug elt tap-oracle target-csv
[2021-05-05 14:04:38,856] [21520|MainThread|root] [DEBUG] Creating engine <meltano.core.project.Project object at 0x000001F96C087970>@sqlite:///C:\code\meltano-windowstest2/.meltano/meltano.db
[2021-05-05 14:04:38,888] [21520|MainThread|asyncio] [DEBUG] Using proactor: IocpProactor
meltano | DEBUG Starting new HTTPS connection (1): www.meltano.com:443
meltano | DEBUG https://www.meltano.com:443 "GET /discovery.yml?project_id=1281de93-235e-4185-85ce-2b3555a991ae HTTP/1.1" 200 103053
meltano | DEBUG Variable '$MELTANO_LOAD_SCHEMA' is missing from the environment.
meltano | INFO Running extract & load...
meltano | DEBUG Created configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T180438--tap-oracle--target-csv\8b145347-43c8-402e-ac5f-1e297b0e2f0a\tap.config.json
meltano | DEBUG Could not find tap.properties.json in C:\code\meltano-windowstest2\.meltano\extractors\tap-oracle\tap.properties.json, skipping.
meltano | DEBUG Could not find tap.properties.cache_key in C:\code\meltano-windowstest2\.meltano\extractors\tap-oracle\tap.properties.cache_key, skipping.
meltano | DEBUG Could not find state.json in C:\code\meltano-windowstest2\.meltano\extractors\tap-oracle\state.json, skipping.
meltano | DEBUG Variable '$MELTANO_LOAD_SCHEMA' is missing from the environment.
meltano | DEBUG Variable '$MELTANO_LOAD_SCHEMA' is missing from the environment.
meltano | DEBUG Created configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T180438--tap-oracle--target-csv\8b145347-43c8-402e-ac5f-1e297b0e2f0a\target.config.json
meltano | WARNING No state was found, complete import.
meltano | INFO Found catalog in C:\code\meltano-windowstest2\powerschoolcatalog.json
meltano | DEBUG Deleted configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T180438--tap-oracle--target-csv\8b145347-43c8-402e-ac5f-1e297b0e2f0a\target.config.json
meltano | DEBUG Deleted configuration at C:\code\meltano-windowstest2\.meltano\run\elt\2021-05-05T180438--tap-oracle--target-csv\8b145347-43c8-402e-ac5f-1e297b0e2f0a\tap.config.json
meltano | DEBUG ELT could not be completed: Cannot start extractor: Catalog discovery failed: invalid catalog: Expecting value: line 1 column 1 (char 0)
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\plugin\singer\tap.py", line 263, in discover_catalog
catalog = json.load(catalog_file)
File "c:\users\derek\appdata\local\programs\python\python38\lib\json\__init__.py", line 293, in load
return loads(fp.read(),
File "c:\users\derek\appdata\local\programs\python\python38\lib\json\__init__.py", line 357, in loads
return _default_decoder.decode(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\json\decoder.py", line 337, in decode
obj, end = self.raw_decode(s, idx=_w(s, 0).end())
File "c:\users\derek\appdata\local\programs\python\python38\lib\json\decoder.py", line 355, in raw_decode
raise JSONDecodeError("Expecting value", s, err.value) from None
json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\runner\singer.py", line 95, in invoke
p_tap = await tap.invoke_async(
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\plugin_invoker.py", line 231, in invoke_async
with self._invoke(*args, **kwargs) as (popen_args, popen_options, popen_env):
File "c:\users\derek\appdata\local\programs\python\python38\lib\contextlib.py", line 113, in __enter__
return next(self.gen)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\plugin_invoker.py", line 212, in _invoke
with self.plugin.trigger_hooks("invoke", self, args):
File "c:\users\derek\appdata\local\programs\python\python38\lib\contextlib.py", line 113, in __enter__
return next(self.gen)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\behavior\hookable.py", line 70, in trigger_hooks
self.__class__.trigger(self, f"before_{hook_name}", *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\behavior\hookable.py", line 97, in trigger
raise err
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\behavior\hookable.py", line 89, in trigger
hook_func(target, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\plugin\singer\tap.py", line 217, in discover_catalog_hook
self.discover_catalog(plugin_invoker, exec_args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\plugin\singer\tap.py", line 267, in discover_catalog
raise PluginExecutionError(
meltano.core.plugin.error.PluginExecutionError: Catalog discovery failed: invalid catalog: Expecting value: line 1 column 1 (char 0)
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 237, in _run_elt
await _run_extract_load(elt_context, output_logger)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 275, in _run_extract_load
await singer_runner.run(
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\runner\singer.py", line 257, in run
await self.invoke(
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\runner\singer.py", line 101, in invoke
raise RunnerError(f"Cannot start extractor: {err}") from err
meltano.core.runner.RunnerError: Cannot start extractor: Catalog discovery failed: invalid catalog: Expecting value: line 1 column 1 (char 0)
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 225, in _redirect_output
yield
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 246, in _run_elt
raise CliError(f"ELT could not be completed: {err}") from err
meltano.cli.utils.CliError: ELT could not be completed: Cannot start extractor: Catalog discovery failed: invalid catalog: Expecting value: line 1 column 1 (char 0)
meltano | WARNING Executing <Task pending name='Task-1' coro=<_run_job() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py:214> wait_for=<Task pending name='Task-4' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:192> cb=[<TaskWakeupMethWrapper object at 0x000001F972E2D9A0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148> cb=[_run_until_complete_cb() at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:184] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py:37> took 1.000 seconds
meltano | DEBUG <_ProactorReadPipeTransport fd=4>: Fatal read error on pipe transport
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
meltano | ERROR Exception in callback _ProactorReadPipeTransport._loop_reading()
handle: <Handle _ProactorReadPipeTransport._loop_reading() created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py:187>
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 201, in _read_from_fd
read_transport, _ = await loop.connect_read_pipe(
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1525, in connect_read_pipe
transport = self._make_read_pipe_transport(pipe, protocol, waiter)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 664, in _make_read_pipe_transport
return _ProactorReadPipeTransport(self, sock, protocol, waiter, extra)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 187, in __init__
self._loop.call_soon(self._loop_reading)
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 309, in _loop_reading
self._fatal_error(exc, 'Fatal read error on pipe transport')
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 131, in _fatal_error
self._force_close(exc)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 134, in _force_close
if self._empty_waiter is not None and not self._empty_waiter.done():
AttributeError: '_ProactorReadPipeTransport' object has no attribute '_empty_waiter'
meltano | DEBUG <_ProactorReadPipeTransport fd=6>: Fatal read error on pipe transport
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
meltano | ERROR Exception in callback _ProactorReadPipeTransport._loop_reading()
handle: <Handle _ProactorReadPipeTransport._loop_reading() created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py:187>
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 201, in _read_from_fd
read_transport, _ = await loop.connect_read_pipe(
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1525, in connect_read_pipe
transport = self._make_read_pipe_transport(pipe, protocol, waiter)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 664, in _make_read_pipe_transport
return _ProactorReadPipeTransport(self, sock, protocol, waiter, extra)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 187, in __init__
self._loop.call_soon(self._loop_reading)
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 299, in _loop_reading
self._read_fut = self._loop._proactor.recv(self._sock, 32768)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 445, in recv
self._register_with_iocp(conn)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 718, in _register_with_iocp
_overlapped.CreateIoCompletionPort(obj.fileno(), self._iocp, 0, 0)
OSError: [WinError 87] The parameter is incorrect
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 309, in _loop_reading
self._fatal_error(exc, 'Fatal read error on pipe transport')
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 131, in _fatal_error
self._force_close(exc)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\proactor_events.py", line 134, in _force_close
if self._empty_waiter is not None and not self._empty_waiter.done():
AttributeError: '_ProactorReadPipeTransport' object has no attribute '_empty_waiter'
meltano | DEBUG Read pipe 4 connected: (<_ProactorReadPipeTransport fd=4>, <asyncio.streams.StreamReaderProtocol object at 0x000001F972CF7B20>)
meltano | DEBUG Read pipe 6 connected: (<_ProactorReadPipeTransport fd=6>, <asyncio.streams.StreamReaderProtocol object at 0x000001F972CF7CD0>)
Aborted!
Exception ignored in: <coroutine object _run_job at 0x000001F972C520C0>
RuntimeError: coroutine ignored GeneratorExit
meltano | ERROR Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 194, in _run_module_as_main
return _run_code(code, main_globals, None,
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 87, in _run_code
exec(code, run_globals)
File "C:\Users\derek\AppData\Local\Programs\Python\Python38\Scripts\meltano.exe\__main__.py", line 7, in <module>
sys.exit(main())
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\__init__.py", line 43, in main
cli(obj={"project": None})
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 782, in main
rv = self.invoke(ctx)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 610, in invoke
return callback(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 23, in decorate
return func(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 57, in decorate
func(project, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 137, in elt
run_async(_run_job(project, job, session, context_builder, force=force))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py", line 37, in run_async
future = asyncio.ensure_future(coro)
task: <Task pending name='Task-1' coro=<_run_job() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py:214> wait_for=<Task pending name='Task-4' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001F972CF7CA0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001F972E2D9A0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148> created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py:37>
--- Logging error ---
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\logging\__init__.py", line 1084, in emit
stream.write(msg + self.terminator)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 65, in write
self.__out.writeline(line)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 174, in writeline
click.echo(self.prefix + line, nl=False, file=self)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\utils.py", line 272, in echo
file.write(message)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\_compat.py", line 710, in _safe_write
return _write(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 41, in write
self.__convertor.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 164, in write
self.wrapped.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 179, in write
self.file.write(remove_ansi_escape_sequences(data))
ValueError: I/O operation on closed file.
Call stack:
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1733, in call_exception_handler
self.default_exception_handler(context)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1707, in default_exception_handler
logger.error('\n'.join(log_lines), exc_info=exc_info)
Message: 'Task was destroyed but it is pending!\nsource_traceback: Object created at (most recent call last):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 194, in _run_module_as_main\n return _run_code(code, main_globals, None,\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 87, in _run_code\n exec(code, run_globals)\n File "C:\\Users\\derek\\AppData\\Local\\Programs\\Python\\Python38\\Scripts\\meltano.exe\\__main__.py", line 7, in <module>\n sys.exit(main())\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\__init__.py", line 43, in main\n cli(obj={"project": None})\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 829, in __call__\n return self.main(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 782, in main\n rv = self.invoke(ctx)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1259, in invoke\n return _process_result(sub_ctx.command.invoke(sub_ctx))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1066, in invoke\n return ctx.invoke(self.callback, **ctx.params)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 610, in invoke\n return callback(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 23, in decorate\n return func(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 57, in decorate\n func(project, *args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 137, in elt\n run_async(_run_job(project, job, session, context_builder, force=force))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py", line 37, in run_async\n future = asyncio.ensure_future(coro)\ntask: <Task pending name=\'Task-1\' coro=<_run_job() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py:214> wait_for=<Task pending name=\'Task-4\' coro=<Out._read_from_fd() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001F972CF7CA0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001F972E2D9A0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:148> created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py:37>'
Arguments: ()
Exception ignored in: <generator object Job._handling_sigterm at 0x000001F972CD6AC0>
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\job\job.py", line 229, in _handling_sigterm
signal.signal(signal.SIGTERM, original_termination_handler)
File "c:\users\derek\appdata\local\programs\python\python38\lib\signal.py", line 47, in signal
handler = _signal.signal(_enum_to_int(signalnum), _enum_to_int(handler))
TypeError: signal handler must be signal.SIG_IGN, signal.SIG_DFL, or a callable object
meltano | ERROR Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 194, in _run_module_as_main
return _run_code(code, main_globals, None,
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 87, in _run_code
exec(code, run_globals)
File "C:\Users\derek\AppData\Local\Programs\Python\Python38\Scripts\meltano.exe\__main__.py", line 7, in <module>
sys.exit(main())
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\__init__.py", line 43, in main
cli(obj={"project": None})
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 782, in main
rv = self.invoke(ctx)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 610, in invoke
return callback(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 23, in decorate
return func(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 57, in decorate
func(project, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 137, in elt
run_async(_run_job(project, job, session, context_builder, force=force))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py", line 39, in run_async
loop.run_until_complete(future)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 603, in run_until_complete
self.run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 214, in _run_job
await _run_elt(project, context_builder, output_logger)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 232, in _run_elt
async with _redirect_output(output_logger):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 223, in _redirect_output
async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 161, in redirect_stdout
async with self.writer() as stdout:
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 148, in writer
reader = asyncio.ensure_future(self._read_from_fd(read_fd))
task: <Task pending name='Task-3' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001F972CF7AF0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148>
--- Logging error ---
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\logging\__init__.py", line 1084, in emit
stream.write(msg + self.terminator)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 65, in write
self.__out.writeline(line)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 174, in writeline
click.echo(self.prefix + line, nl=False, file=self)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\utils.py", line 272, in echo
file.write(message)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\_compat.py", line 710, in _safe_write
return _write(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 41, in write
self.__convertor.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 164, in write
self.wrapped.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 179, in write
self.file.write(remove_ansi_escape_sequences(data))
ValueError: I/O operation on closed file.
Call stack:
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1733, in call_exception_handler
self.default_exception_handler(context)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1707, in default_exception_handler
logger.error('\n'.join(log_lines), exc_info=exc_info)
Message: 'Task was destroyed but it is pending!\nsource_traceback: Object created at (most recent call last):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 194, in _run_module_as_main\n return _run_code(code, main_globals, None,\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 87, in _run_code\n exec(code, run_globals)\n File "C:\\Users\\derek\\AppData\\Local\\Programs\\Python\\Python38\\Scripts\\meltano.exe\\__main__.py", line 7, in <module>\n sys.exit(main())\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\__init__.py", line 43, in main\n cli(obj={"project": None})\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 829, in __call__\n return self.main(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 782, in main\n rv = self.invoke(ctx)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1259, in invoke\n return _process_result(sub_ctx.command.invoke(sub_ctx))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1066, in invoke\n return ctx.invoke(self.callback, **ctx.params)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 610, in invoke\n return callback(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 23, in decorate\n return func(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 57, in decorate\n func(project, *args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 137, in elt\n run_async(_run_job(project, job, session, context_builder, force=force))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py", line 39, in run_async\n loop.run_until_complete(future)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 603, in run_until_complete\n self.run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\windows_events.py", line 316, in run_forever\n super().run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 570, in run_forever\n self._run_once()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 1851, in _run_once\n handle._run()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\events.py", line 81, in _run\n self._context.run(self._callback, *self._args)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 214, in _run_job\n await _run_elt(project, context_builder, output_logger)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 232, in _run_elt\n async with _redirect_output(output_logger):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 223, in _redirect_output\n async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 161, in redirect_stdout\n async with self.writer() as stdout:\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 148, in writer\n reader = asyncio.ensure_future(self._read_from_fd(read_fd))\ntask: <Task pending name=\'Task-3\' coro=<Out._read_from_fd() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001F972CF7AF0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py:422> created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:148>'
Arguments: ()
meltano | ERROR Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 194, in _run_module_as_main
return _run_code(code, main_globals, None,
File "c:\users\derek\appdata\local\programs\python\python38\lib\runpy.py", line 87, in _run_code
exec(code, run_globals)
File "C:\Users\derek\AppData\Local\Programs\Python\Python38\Scripts\meltano.exe\__main__.py", line 7, in <module>
sys.exit(main())
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\__init__.py", line 43, in main
cli(obj={"project": None})
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 782, in main
rv = self.invoke(ctx)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\core.py", line 610, in invoke
return callback(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 23, in decorate
return func(*args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\params.py", line 57, in decorate
func(project, *args, **kwargs)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 137, in elt
run_async(_run_job(project, job, session, context_builder, force=force))
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\utils\__init__.py", line 39, in run_async
loop.run_until_complete(future)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 603, in run_until_complete
self.run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\windows_events.py", line 316, in run_forever
super().run_forever()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 570, in run_forever
self._run_once()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1851, in _run_once
handle._run()
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\events.py", line 81, in _run
self._context.run(self._callback, *self._args)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 214, in _run_job
await _run_elt(project, context_builder, output_logger)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 232, in _run_elt
async with _redirect_output(output_logger):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\cli\elt.py", line 223, in _redirect_output
async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 167, in redirect_stderr
async with self.writer() as stderr:
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 34, in __aenter__
return await self._agen.asend(None)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 148, in writer
reader = asyncio.ensure_future(self._read_from_fd(read_fd))
task: <Task pending name='Task-4' coro=<Out._read_from_fd() running at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001F972CF7CA0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001F972E2D9A0>()] created at c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py:148>
--- Logging error ---
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\logging\__init__.py", line 1084, in emit
stream.write(msg + self.terminator)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 65, in write
self.__out.writeline(line)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 174, in writeline
click.echo(self.prefix + line, nl=False, file=self)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\utils.py", line 272, in echo
file.write(message)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\click\_compat.py", line 710, in _safe_write
return _write(s)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 41, in write
self.__convertor.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\colorama\ansitowin32.py", line 164, in write
self.wrapped.write(text)
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\meltano\core\logging\output_logger.py", line 179, in write
self.file.write(remove_ansi_escape_sequences(data))
ValueError: I/O operation on closed file.
Call stack:
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1733, in call_exception_handler
self.default_exception_handler(context)
File "c:\users\derek\appdata\local\programs\python\python38\lib\asyncio\base_events.py", line 1707, in default_exception_handler
logger.error('\n'.join(log_lines), exc_info=exc_info)
Message: 'Task was destroyed but it is pending!\nsource_traceback: Object created at (most recent call last):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 194, in _run_module_as_main\n return _run_code(code, main_globals, None,\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\runpy.py", line 87, in _run_code\n exec(code, run_globals)\n File "C:\\Users\\derek\\AppData\\Local\\Programs\\Python\\Python38\\Scripts\\meltano.exe\\__main__.py", line 7, in <module>\n sys.exit(main())\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\__init__.py", line 43, in main\n cli(obj={"project": None})\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 829, in __call__\n return self.main(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 782, in main\n rv = self.invoke(ctx)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1259, in invoke\n return _process_result(sub_ctx.command.invoke(sub_ctx))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 1066, in invoke\n return ctx.invoke(self.callback, **ctx.params)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\click\\core.py", line 610, in invoke\n return callback(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 23, in decorate\n return func(*args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\params.py", line 57, in decorate\n func(project, *args, **kwargs)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 137, in elt\n run_async(_run_job(project, job, session, context_builder, force=force))\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\utils\\__init__.py", line 39, in run_async\n loop.run_until_complete(future)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 603, in run_until_complete\n self.run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\windows_events.py", line 316, in run_forever\n super().run_forever()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 570, in run_forever\n self._run_once()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py", line 1851, in _run_once\n handle._run()\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\events.py", line 81, in _run\n self._context.run(self._callback, *self._args)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 214, in _run_job\n await _run_elt(project, context_builder, output_logger)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 232, in _run_elt\n async with _redirect_output(output_logger):\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\cli\\elt.py", line 223, in _redirect_output\n async with meltano_stdout.redirect_stdout(), meltano_stderr.redirect_stderr():\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 167, in redirect_stderr\n async with self.writer() as stderr:\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\async_generator\\_util.py", line 34, in __aenter__\n return await self._agen.asend(None)\n File "c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py", line 148, in writer\n reader = asyncio.ensure_future(self._read_from_fd(read_fd))\ntask: <Task pending name=\'Task-4\' coro=<Out._read_from_fd() running at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:205> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x000001F972CF7CA0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\asyncio\\base_events.py:422> cb=[<TaskWakeupMethWrapper object at 0x000001F972E2D9A0>()] created at c:\\users\\derek\\appdata\\local\\programs\\python\\python38\\lib\\site-packages\\meltano\\core\\logging\\output_logger.py:148>'
Arguments: ()
Exception ignored in: <coroutine object _AsyncGeneratorContextManager.__aexit__ at 0x000001F972D5CF40>
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 84, in __aexit__
raise
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 14, in __aexit__
await self._aiter.aclose()
RuntimeError: aclose(): asynchronous generator is already running
Exception ignored in: <coroutine object _AsyncGeneratorContextManager.__aexit__ at 0x000001F972DCA140>
Traceback (most recent call last):
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 84, in __aexit__
raise
File "c:\users\derek\appdata\local\programs\python\python38\lib\site-packages\async_generator\_util.py", line 14, in __aexit__
await self._aiter.aclose()
RuntimeError: aclose(): asynchronous generator is already runningEdited by Derek Visch