gravingPro

> Hi @gravingPro, > > A quick follow-up question. How is your custom sink defined? In `read_sql` the argument `sql` is currently unused. It's just a simple example. Any sink...

> Hi @gravingPro, > > Is `read_sql` your sink, because the comment suggests `spark.sql() # sink custom` is the sink? If `spark.sql()` is the sink, then the flow will stop...

As said in description, it's found in the projects using multiprocess functions as **"threading.Thread"**, **"concurrent.futures.Executor"** and **"multiprocessing.Process"**. The CodeQL cannot get the path. ```python # example import threading import time...