@Override
    String runIgnoringInputs(String code) {
        """
            def executors = ${executors}
            def future = ${CompletableFuture.name}.runAsync({
                ${code}
            }, executors.userJobExecutor)

            // Block until the job completes to ensure it run at the configuration time.
            future.get()
        """
    }

        }
    }

    private CompletableFuture<Void> startAsyncCleanupAfterBuild() {
        return userHomeServiceRegistry.getCurrentServices()
            .map(serviceRegistry ->
                CompletableFuture.runAsync(() -> {
                    LOGGER.debug("Cleaning virtual file system after build finished");
                    BuildLifecycleAwareVirtualFileSystem virtualFileSystem = serviceRegistry.get(BuildLifecycleAwareVirtualFileSystem.class);

    except Exception as e:
        ok = bool(
            await anyio.to_thread.run_sync(
                cm.__exit__, type(e), e, None, limiter=exit_limiter
            )
        )
        if not ok:
            raise e
    else:
        await anyio.to_thread.run_sync(
            cm.__exit__, None, None, None, limiter=exit_limiter

that in each workspace module.

See the workspaces reference at https://go.dev/ref/mod#workspaces
for more information.
`,
	Run: runSync,
}

func init() {
	base.AddChdirFlag(&cmdSync.Flag)
	base.AddModCommonFlags(&cmdSync.Flag)
}

func runSync(ctx context.Context, cmd *base.Command, args []string) {
	modload.ForceUseModules = true
	modload.InitWorkfile()
	if modload.WorkFilePath() == "" {