From 19314c0ceef1dd29db42a59f11ef3c1127b122af Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Thu, 21 Mar 2024 19:07:05 +0000 Subject: [PATCH] fix lint --- flow/connectors/kafka/kafka.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go index 2090c5e617..ff491ddc8c 100644 --- a/flow/connectors/kafka/kafka.go +++ b/flow/connectors/kafka/kafka.go @@ -158,7 +158,7 @@ func (c *KafkaConnector) SyncFlowCleanup(ctx context.Context, jobName string) er return c.pgMetadata.DropMetadata(ctx, jobName) } -func loadScript(ctx context.Context, script string, print lua.LGFunction) (*lua.LState, error) { +func loadScript(ctx context.Context, script string, printfn lua.LGFunction) (*lua.LState, error) { if script == "" { return nil, errors.New("kafka mirror must have script") } @@ -185,7 +185,7 @@ func loadScript(ctx context.Context, script string, print lua.LGFunction) (*lua. } ls.PreloadModule("flatbuffers", gluaflatbuffers.Loader) pua.RegisterTypes(ls) - ls.Env.RawSetString("print", ls.NewFunction(print)) + ls.Env.RawSetString("print", ls.NewFunction(printfn)) err := ls.GPCall(pua.LoadPeerdbScript, lua.LString(script)) if err != nil { return nil, fmt.Errorf("error loading script %s: %w", script, err)