Run invocation could not be completed as block failed: Loader failed ╭─────────────────────────────── Traceback (most recent call last) ────────────────────────────────╮ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/run.py:173 in │ │ _run_blocks │ │ │ │ 170 │ │ │ continue │ │ 171 │ │ │ │ 172 │ │ try: │ │ ❱ 173 │ │ │ await blk.run() │ │ 174 │ │ except RunnerError as err: │ │ 175 │ │ │ logger.error( │ │ 176 │ │ │ │ "Block run completed.", │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/core/block/extract_ │ │ load.py:444 in run │ │ │ │ 441 │ │ │ # TODO: legacy `meltano elt` style logging should be deprecated │ │ 442 │ │ │ legacy_log_handler = self.output_logger.out("meltano", logger) │ │ 443 │ │ │ with legacy_log_handler.redirect_logging(): │ │ ❱ 444 │ │ │ │ await self.run_with_job() │ │ 445 │ │ │ │ return │ │ 446 │ │ else: │ │ 447 │ │ │ logger.warning( │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/core/block/extract_ │ │ load.py:476 in run_with_job │ │ │ │ 473 │ │ │ │ 474 │ │ with closing(self.context.session) as session: │ │ 475 │ │ │ async with job.run(session): │ │ ❱ 476 │ │ │ │ await self.execute() │ │ 477 │ │ │ 478 │ async def terminate(self, graceful: bool = False) -> None: │ │ 479 │ │ """Terminate an in flight ExtractLoad execution, potentially disruptive. │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/core/block/extract_ │ │ load.py:436 in execute │ │ │ │ 433 │ │ async with self._start_blocks(): │ │ 434 │ │ │ await self._link_io() │ │ 435 │ │ │ manager = ELBExecutionManager(self) │ │ ❱ 436 │ │ │ await manager.run() │ │ 437 │ │ │ 438 │ async def run(self) -> None: │ │ 439 │ │ """Run the ELT task.""" │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/core/block/extract_ │ │ load.py:642 in run │ │ │ │ 639 │ │ any of the blocks exit with a non 0 exit code. │ │ 640 │ │ """ │ │ 641 │ │ await self._wait_for_process_completion(self.elb.head) │ │ ❱ 642 │ │ _check_exit_codes( │ │ 643 │ │ │ self._producer_code, │ │ 644 │ │ │ self._consumer_code, │ │ 645 │ │ │ self._intermediate_codes, │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/core/block/extract_ │ │ load.py:813 in _check_exit_codes │ │ │ │ 810 │ │ raise RunnerError("Extractor failed", {PluginType.EXTRACTORS: producer_code}) │ │ 811 │ │ │ 812 │ if consumer_code: │ │ ❱ 813 │ │ raise RunnerError("Loader failed", {PluginType.LOADERS: consumer_code}) │ │ 814 │ │ │ 815 │ if failed_mappers := [ │ │ 816 │ │ {mapper_id: exit_code} │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────╯ RunnerError: Loader failed The above exception was the direct cause of the following exception: ╭─────────────────────────────── Traceback (most recent call last) ────────────────────────────────╮ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/__init__.py:102 │ │ in _run_cli │ │ │ │ 99 │ """ │ │ 100 │ try: │ │ 101 │ │ try: # noqa: WPS225, WPS505 │ │ ❱ 102 │ │ │ cli(obj={"project": None}) │ │ 103 │ │ except ProjectReadonly as err: │ │ 104 │ │ │ raise CliError( │ │ 105 │ │ │ │ f"The requested action could not be completed: {err}", │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/click/core.py:1157 in │ │ __call__ │ │ │ │ 1154 │ │ │ 1155 │ def __call__(self, *args: t.Any, **kwargs: t.Any) -> t.Any: │ │ 1156 │ │ """Alias for :meth:`main`.""" │ │ ❱ 1157 │ │ return self.main(*args, **kwargs) │ │ 1158 │ │ 1159 │ │ 1160 class Command(BaseCommand): │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/cli.py:42 in │ │ main │ │ │ │ 39 │ │ │ args: Positional arguments for the Click group. │ │ 40 │ │ │ kwargs: Keyword arguments for the Click group. │ │ 41 │ │ """ │ │ ❱ 42 │ │ return super().main(*args, windows_expand_args=False, **kwargs) │ │ 43 │ │ 44 │ │ 45 @click.group( │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/click/core.py:1078 in main │ │ │ │ 1075 │ │ try: │ │ 1076 │ │ │ try: │ │ 1077 │ │ │ │ with self.make_context(prog_name, args, **extra) as ctx: │ │ ❱ 1078 │ │ │ │ │ rv = self.invoke(ctx) │ │ 1079 │ │ │ │ │ if not standalone_mode: │ │ 1080 │ │ │ │ │ │ return rv │ │ 1081 │ │ │ │ │ # it's not safe to `ctx.exit(rv)` here! │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/utils.py:632 in │ │ invoke │ │ │ │ 629 │ │ enact_environment_behavior(self.environment_behavior, ctx) │ │ 630 │ │ if ctx.obj.get("tracker"): │ │ 631 │ │ │ ctx.obj["tracker"].add_contexts(CliContext.from_click_context(ctx)) │ │ ❱ 632 │ │ super().invoke(ctx) │ │ 633 │ │ 634 │ │ 635 class InstrumentedDefaultGroup(InstrumentedGroupMixin, DefaultGroup, DYMGroup): │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/click/core.py:1688 in │ │ invoke │ │ │ │ 1685 │ │ │ │ super().invoke(ctx) │ │ 1686 │ │ │ │ sub_ctx = cmd.make_context(cmd_name, args, parent=ctx) │ │ 1687 │ │ │ │ with sub_ctx: │ │ ❱ 1688 │ │ │ │ │ return _process_result(sub_ctx.command.invoke(sub_ctx)) │ │ 1689 │ │ │ │ 1690 │ │ # In chain mode we create the contexts step by step, but after the │ │ 1691 │ │ # base command has been invoked. Because at that point we do not │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/utils.py:681 in │ │ invoke │ │ │ │ 678 │ │ if ctx.obj.get("tracker"): │ │ 679 │ │ │ ctx.obj["tracker"].add_contexts(CliContext.from_click_context(ctx)) │ │ 680 │ │ │ ctx.obj["tracker"].track_command_event(CliEvent.started) │ │ ❱ 681 │ │ super().invoke(ctx) │ │ 682 │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/click/core.py:1434 in │ │ invoke │ │ │ │ 1431 │ │ │ echo(style(message, fg="red"), err=True) │ │ 1432 │ │ │ │ 1433 │ │ if self.callback is not None: │ │ ❱ 1434 │ │ │ return ctx.invoke(self.callback, **ctx.params) │ │ 1435 │ │ │ 1436 │ def shell_complete(self, ctx: Context, incomplete: str) -> t.List["CompletionItem"]: │ │ 1437 │ │ """Return a list of completions for the incomplete value. Looks │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/click/core.py:783 in invoke │ │ │ │ 780 │ │ │ │ 781 │ │ with augment_usage_errors(__self): │ │ 782 │ │ │ with ctx: │ │ ❱ 783 │ │ │ │ return __callback(*args, **kwargs) │ │ 784 │ │ │ 785 │ def forward( │ │ 786 │ │ __self, __cmd: "Command", *args: t.Any, **kwargs: t.Any # noqa: B902 │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/params.py:27 in │ │ decorate │ │ │ │ 24 │ │ if database_uri: │ │ 25 │ │ │ ProjectSettingsService.config_override["database_uri"] = database_uri │ │ 26 │ │ │ │ ❱ 27 │ │ return func(*args, **kwargs) │ │ 28 │ │ │ 29 │ return functools.update_wrapper(decorate, func) │ │ 30 │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/params.py:75 in │ │ decorate │ │ │ │ 72 │ │ │ │ except MigrationError as err: │ │ 73 │ │ │ │ │ raise CliError(str(err)) from err │ │ 74 │ │ │ │ │ ❱ 75 │ │ │ func(project, *args, **kwargs) │ │ 76 │ │ │ │ 77 │ │ return functools.update_wrapper(decorate, func) │ │ 78 │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/click/decorators.py:33 in │ │ new_func │ │ │ │ 30 │ """ │ │ 31 │ │ │ 32 │ def new_func(*args: "P.args", **kwargs: "P.kwargs") -> "R": │ │ ❱ 33 │ │ return f(get_current_context(), *args, **kwargs) │ │ 34 │ │ │ 35 │ return update_wrapper(new_func, f) │ │ 36 │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/core/utils/__init__ │ │ .py:74 in wrapper │ │ │ │ 71 │ │ │ 72 │ @functools.wraps(func) │ │ 73 │ def wrapper(*args, **kwargs): │ │ ❱ 74 │ │ return asyncio.run(func(*args, **kwargs)) │ │ 75 │ │ │ 76 │ return wrapper │ │ 77 │ │ │ │ /Users/maciej/.pyenv/versions/3.10.8/lib/python3.10/asyncio/runners.py:44 in run │ │ │ │ 41 │ │ events.set_event_loop(loop) │ │ 42 │ │ if debug is not None: │ │ 43 │ │ │ loop.set_debug(debug) │ │ ❱ 44 │ │ return loop.run_until_complete(main) │ │ 45 │ finally: │ │ 46 │ │ try: │ │ 47 │ │ │ _cancel_all_tasks(loop) │ │ │ │ /Users/maciej/.pyenv/versions/3.10.8/lib/python3.10/asyncio/base_events.py:649 in │ │ run_until_complete │ │ │ │ 646 │ │ if not future.done(): │ │ 647 │ │ │ raise RuntimeError('Event loop stopped before Future completed.') │ │ 648 │ │ │ │ ❱ 649 │ │ return future.result() │ │ 650 │ │ │ 651 │ def stop(self): │ │ 652 │ │ """Stop running the event loop. │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/run.py:142 in │ │ run │ │ │ │ 139 │ │ await _run_blocks(tracker, parsed_blocks, dry_run=dry_run) │ │ 140 │ except Exception as err: │ │ 141 │ │ tracker.track_command_event(CliEvent.failed) │ │ ❱ 142 │ │ raise err │ │ 143 │ tracker.track_command_event(CliEvent.completed) │ │ 144 │ │ 145 │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/run.py:139 in │ │ run │ │ │ │ 136 │ │ tracker.track_command_event(CliEvent.aborted) │ │ 137 │ │ raise CliError("Some ExtractLoadBlocks set failed validation.") │ │ 138 │ try: │ │ ❱ 139 │ │ await _run_blocks(tracker, parsed_blocks, dry_run=dry_run) │ │ 140 │ except Exception as err: │ │ 141 │ │ tracker.track_command_event(CliEvent.failed) │ │ 142 │ │ raise err │ │ │ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/run.py:185 in │ │ _run_blocks │ │ │ │ 182 │ │ │ ) │ │ 183 │ │ │ with tracker.with_contexts(tracking_ctx): │ │ 184 │ │ │ │ tracker.track_block_event(blk_name, BlockEvents.failed) │ │ ❱ 185 │ │ │ raise CliError( │ │ 186 │ │ │ │ f"Run invocation could not be completed as block failed: {err}", │ │ 187 │ │ │ ) from err │ │ 188 │ │ except Exception as bare_err: │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────╯ CliError: Run invocation could not be completed as block failed: Loader failed The above exception was the direct cause of the following exception: ╭─────────────────────────────── Traceback (most recent call last) ────────────────────────────────╮ │ /Users/maciej/00_codes/meltano/test_env/lib/python3.10/site-packages/meltano/cli/__init__.py:112 │ │ in _run_cli │ │ │ │ 109 │ │ except MeltanoError as err: │ │ 110 │ │ │ handle_meltano_error(err) │ │ 111 │ │ except Exception as err: │ │ ❱ 112 │ │ │ raise CliError(f"{troubleshooting_message}\n{err}") from err │ │ 113 │ except CliError as cli_error: │ │ 114 │ │ cli_error.print() │ │ 115 │ │ sys.exit(1) │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────╯ CliError: Need help fixing this problem? Visit http://melta.no/ for troubleshooting steps, or to join our friendly Slack community. Run invocation could not be completed as block failed: Loader failed Need help fixing this problem? Visit http://melta.no/ for troubleshooting steps, or to join our friendly Slack community. Run invocation could not be completed as block failed: Loader failed