stephen_wood
11/15/2023, 5:05 PMtap-postgres
and loader target-s3
. But when I run meltano run tap-postgres target-s3
it fails with the error message about batch_start_time
being missing from the context:
batch_start = self.context["batch_start_time"] cmd_type=elb consumer=True name=target-s3 producer=False stdio=stderr string_id=target-s3
2023-11-15T16:48:57.803500Z [info ] KeyError: 'batch_start_time' cmd_type=elb consumer=True name=target-s3 producer=False stdio=stderr string_id=target-s3
2023-11-15T16:48:57.972244Z [error ] Loader failed
2023-11-15T16:48:57.972624Z [error ] Block run completed.
As far as I can tell the postgres extractor works correctly (.json.gzip files are saved locally).
I’d be grateful for any help with the possible causes of this error. I’m on a fresh install of meltano 3.1.0 (using pipx) on python 3.11.5 (also tried 3.10.12) and Ubuntu 22.04.3 (also same on mac Sonoma). This is my `meltano.yml`:
version: 1
default_environment: dev
project_id: f8f29104-1e08-4e22-bed2-88aa9137d411
environments:
- name: dev
config:
plugins:
extractors:
- name: tap-postgres
config:
batch_config:
encoding:
compression: gzip
format: jsonl
storage:
root: tap-output
replication_method: FULL_TABLE
select:
- public-my_table.*
loaders:
- name: target-s3
config:
append_date_to_filename: false
prefix: meltano/dev
partition_name_enabled: true
include_process_date: true
format:
format_type: parquet
- name: staging
- name: prod
plugins:
extractors:
- name: tap-postgres
variant: meltanolabs
pip_url: git+<https://github.com/MeltanoLabs/tap-postgres.git>
loaders:
- name: target-s3
variant: crowemi
pip_url: git+<https://github.com/crowemi/target-s3.git>
mark_estey
11/15/2023, 8:04 PM