Jun Pei Liang
02/15/2025, 12:42 AMmeltano run tap-oracle target-parquet
, it executed fine without issue. When i ran meltano run tap-oracle target-s3
, i got Run invocation could not be completed as block failed: Loader failed
.Jun Pei Liang
02/18/2025, 10:32 PM2025-02-18T22:30:32.750627Z [debug ] 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
╭─────────────────────────────── Traceback (most recent call last) ────────────────────────────────╮
│ /root/.local/share/pipx/venvs/meltano/lib/python3.10/site-packages/meltano/cli/run.py:218 in │
│ _run_blocks │
│ │
│ 215 │ │ │ continue │
│ 216 │ │ │
│ 217 │ │ try: │
│ ❱ 218 │ │ │ await blk.run() │
│ 219 │ │ except RunnerError as err: │
│ 220 │ │ │ logger.error( │
│ 221 │ │ │ │ "Block run completed.", │
│ │
│ /root/.local/share/pipx/venvs/meltano/lib/python3.10/site-packages/meltano/core/block/extract_lo │
│ ad.py:509 in run │
│ │
│ 506 │ │ │ # TODO: legacy `meltano elt` style logging should be deprecated │
│ 507 │ │ │ legacy_log_handler = self.output_logger.out("meltano", logger) │
│ 508 │ │ │ with legacy_log_handler.redirect_logging(): │
│ ❱ 509 │ │ │ │ await self.run_with_job() │
│ 510 │ │ │ │ return │
│ 511 │ │ else: │
│ 512 │ │ │ logger.warning( │
│ │
│ /root/.local/share/pipx/venvs/meltano/lib/python3.10/site-packages/meltano/core/block/extract_lo │
│ ad.py:546 in run_with_job │
│ │
│ 543 │ │ │
│ 544 │ │ with closing(self.context.session) as session: │
│ 545 │ │ │ async with job.run(session): │
│ ❱ 546 │ │ │ │ await self.execute() │
│ 547 │ │
│ 548 │ async def terminate(self, *, graceful: bool = False) -> None: │
│ 549 │ │ """Terminate an in flight ExtractLoad execution, potentially disruptive. │
│ │
│ /root/.local/share/pipx/venvs/meltano/lib/python3.10/site-packages/meltano/core/block/extract_lo │
│ ad.py:501 in execute │
│ │
│ 498 │ │ async with self._start_blocks(): │
│ 499 │ │ │ await self._link_io() │
│ 500 │ │ │ manager = ELBExecutionManager(self) │
│ ❱ 501 │ │ │ await manager.run() │
│ 502 │ │
│ 503 │ async def run(self) -> None: │
│ 504 │ │ """Run the ELT task.""" │
│ │
│ /root/.local/share/pipx/venvs/meltano/lib/python3.10/site-packages/meltano/core/block/extract_lo │
│ ad.py:714 in run │
│ │
│ 711 │ │ any of the blocks exit with a non 0 exit code. │
│ 712 │ │ """ │
│ 713 │ │ await self._wait_for_process_completion(self.elb.head) │
│ ❱ 714 │ │ _check_exit_codes( │
│ 715 │ │ │ self._producer_code, │
│ 716 │ │ │ self._consumer_code, │
│ 717 │ │ │ self._intermediate_codes, │
│ │
│ /root/.local/share/pipx/venvs/meltano/lib/python3.10/site-packages/meltano/core/block/extract_lo │
│ ad.py:886 in _check_exit_codes │
│ │
│ 883 │ │ raise RunnerError("Extractor failed", {PluginType.EXTRACTORS: producer_code}) # │
│ 884 │ │
│ 885 │ if consumer_code: │
│ ❱ 886 │ │ raise RunnerError("Loader failed", {PluginType.LOADERS: consumer_code}) # noqa: │
│ 887 │ │
│ 888 │ if failed_mappers := [ │
│ 889 │ │ {mapper_id: exit_code} │
╰──────────────────────────────────────────────────────────────────────────────────────────────────╯
RunnerError: Loader failed