From 8749c4cae7a7c8cbc578240fe4a1e067ff4a2d8c Mon Sep 17 00:00:00 2001 From: pblcm Date: Thu, 30 Sep 2021 10:57:42 +0100 Subject: [PATCH] Update __init__.py * fix problem with schema serialization * fix formatting row number in lambda --- .../{{cookiecutter.package_name}}/__init__.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/{{cookiecutter.project_name}}/{{cookiecutter.package_name}}/__init__.py b/{{cookiecutter.project_name}}/{{cookiecutter.package_name}}/__init__.py index 4e0f88c..0e14bc0 100644 --- a/{{cookiecutter.project_name}}/{{cookiecutter.package_name}}/__init__.py +++ b/{{cookiecutter.project_name}}/{{cookiecutter.package_name}}/__init__.py @@ -63,12 +63,12 @@ def sync(config, state, catalog): singer.write_schema( stream_name=stream.tap_stream_id, - schema=stream.schema, + schema=stream.schema.to_dict(), key_properties=stream.key_properties, ) # TODO: delete and replace this inline function with your own data retrieval process: - tap_data = lambda: [{"id": x, "name": "row${x}"} for x in range(1000)] + tap_data = lambda: [{"id": x, "name": f"row {x}"} for x in range(1000)] max_bookmark = None for row in tap_data():