Hi, I'm aware that the Go SDK is not yet supported on Dataflow, but it seems it works well in many situations. However, for the following pipeline [1] I'm getting
> S01:cloudsqlpostgres.Query/Impulse+cloudsqlpostgres.Query/databaseio.queryFn+main.ReadLinksFn+pubsubio.Write/External > failed., The job failed because a work item has failed 4 times. Look in > previous log entries for the cause of each one of the 4 failures. For more > information, see https://cloud.google.com/dataflow/docs/guides/common-errors. > The work item was attempted on these workers: > go-job-1-123-xxx-ox0o-harness-xfbf Root cause: Could not find the sink for > pubsub, Check that the sink library specifies alwayslink = 1. The topic does exist with an attached subscription and permissions and relevant API have otherwise been configured. What am I doing wrong? [1] https://gist.github.com/hnnsgstfssn/ab76d6681cc7130421a9849217aafd7d
