presto-raptor-legacy/src/main/java/io/prestosql/plugin/raptor/legacy/storage/organization/ShardOrganizer.java/ShardOrganizer/enqueue
class ShardOrganizer:    public CompletableFuture<?> enqueue(OrganizationSet organizationSet)
    {
        shardsInProgress.addAll(organizationSet.getShards());
        return runAsync(jobFactory.create(organizationSet), executorService)
                .whenComplete((none, throwable) -> {
                    shardsInProgress.removeAll(organizationSet.getShards());
                    if (throwable == null) {
                        successCount.update(1);
                    }
                    else {
                        log.warn(throwable, "Error running organization job");
                        failureCount.update(1);
                    }
                });
    }