Hello 👋 It looks like the SQLite connection used by Dagster to log events is not thread-safe. The connection is created in one thread and is being used in another thread, causing the following error message :

sqlalchemy.exc.ProgrammingError: (sqlite3.ProgrammingError) SQLite objects created in a thread can only be used in that same thread. The object was created in thread id 140024476800832 and this is thread id 140024381171456.
(Background on this error at: <https://sqlalche.me/e/14/f405>)

Here's how to reproduce the error:

import concurrent.futures

from dagster import get_dagster_logger, graph, op


def my_function(x):
    logger = get_dagster_logger()
    <http://logger.info|logger.info>(f"Got {x=}")
    return x + 1


@op
def my_op():
    with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
        results = list(executor.map(my_function, range(3)))
    print(results)
    return results


@graph
def my_graph() -> None:
    my_op()


def main() -> None:
    my_graph.execute_in_process()


if __name__ == "__main__":
    main()

hi @Félix Tremblay! As of the version of dagster released yesterday (1.1.19), you shouldn't see this error anymore

Thank you @owen!

Looks like the fix landed just after the branch cut so will actually be out in this weeks release on Thursday.

thank you! it works