From 149e8349a1a09007a643cfc12aae2a33c2850e40 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Tue, 12 Mar 2024 23:36:55 +0000 Subject: [PATCH] need to actually call function loader returns.. --- flow/connectors/kafka/kafka.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go index e2c71b0fb1..a5adb705cc 100644 --- a/flow/connectors/kafka/kafka.go +++ b/flow/connectors/kafka/kafka.go @@ -166,17 +166,20 @@ func (c *KafkaConnector) SyncRecords(ctx context.Context, req *model.SyncRecords ls.PreloadModule("flatbuffers", pua.FlatBuffers_Loader) pua.RegisterTypes(ls) err := ls.GPCall(pua.LoadPeerdbScript, lua.LString(req.Script)) + if err != nil { + return nil, fmt.Errorf("error loading script %s: %w", req.Script, err) + } + err = ls.PCall(0, 0, nil) if err != nil { return nil, fmt.Errorf("error executing script %s: %w", req.Script, err) } // discard results, for now rely on globals instead of script returning anything - ls.SetTop(0) var ok bool lfn := ls.Env.RawGetString("onRecord") fn, ok = lfn.(*lua.LFunction) if !ok { - return nil, fmt.Errorf("script should define `onRecord` as function, not %s", lfn.Type()) + return nil, fmt.Errorf("script should define `onRecord` as function, not %s", lfn) } } else { return nil, errors.New("kafka mirror must have script")