§ ÚÇÔi‰ãóN—ddlmZddlZddlZddlZddlmZmZdddddœdd„ZdS)é)Ú annotationsNé)ÚWorkerConnectionÚWorkerConnectionImpl)Ú instance_idÚrewrite_gateway_endpointÚshutdown_signalsÚmax_worker_concurrencyÚappsú@list[tuple[inngest.Inngest, list[inngest.Function[typing.Any]]]]rú str | Nonerú"typing.Callable[[str], str] | Noner úlist[signal.Signals] | Noner ú int | NoneÚreturnrcó*—t|||||¬¦«S)a§ Create a persistent connection to an Inngest server. Args: ---- apps: A list of tuples, where each tuple contains an Inngest client and a list of functions. instance_id: A stable identifier for identifying connected apps. This can be a hostname or other identifier that remains stable across restarts. It defaults to the hostname of the machine. rewrite_gateway_endpoint: A function that rewrites the Inngest server gateway endpoint. shutdown_signals: A list of graceful shutdown signals to handle. Defaults to [SIGTERM, SIGINT]. max_worker_concurrency: The maximum number of worker concurrency to use. Defaults to None. ©r rrr r )rrs ú^/root/projects/qq-shell/venv/lib/python3.11/site-packages/inngest/connect/_internal/connect.pyÚconnectr s*€õ& Ø ØØ!9Ø)Ø5ð  ñ ô ðó) r r rr rrr rr rrr) Ú __future__rÚsignalÚtypingÚinngestÚ connectionrrr©rrúrs€ðØ"Ð"Ð"Ð"Ð"Ð"à € € € Ø € € € à€€€à>Ð>Ð>Ð>Ð>Ð>Ð>Ð>ð #ØCGØ48Ø)-ð ðððððððr