diff --git a/usecases/lambda/main.py b/usecases/lambda/main.py
index 8d6ad79e..7a3fe894 100644
--- a/usecases/lambda/main.py
+++ b/usecases/lambda/main.py
@@ -19,11 +19,11 @@ def send_message(seq, device, temp):
         schema_name="events",
         typ=0,
         old=None,
-        new=types_pb2.Record(values=[
+        new=[
             types_pb2.Value(string_value=device),
             types_pb2.Value(float_value=temp),
             types_pb2.Value(string_value=datetime.datetime.now().strftime("%H:%M:%S"))
-        ]),
+        ],
         seq_no=seq
     )
     res = ingestion_client.ingest_raw(user)
diff --git a/usecases/lambda/reader.py b/usecases/lambda/reader.py
index 4dc60427..778b674d 100644
--- a/usecases/lambda/reader.py
+++ b/usecases/lambda/reader.py
@@ -20,7 +20,7 @@ def message():
 
 
 async def main():
-    reader = await pydozer_log.LogReader.new("./.dozer", "events")
+    reader = await pydozer_log.LogReader.new("http://127.0.0.1:50053", "events")
     while True:
         data = await reader.next_op()
         if "op" in data.keys():