Creates a new SchedulerSession for this Scheduler.
497926
def new_session(self, zipkin_trace_v2, v2_ui=False):
    """"""
    return SchedulerSession(self, self._native.new_session(
      self._scheduler, zipkin_trace_v2, v2_ui, multiprocessing.cpu_count())
    )
351194
public void schedule(JobDetail jobDetail, Trigger trigger) throws MangooSchedulerException {
        Objects.requireNonNull(jobDetail, Required.JOB_DETAIL.toString());
        Objects.requireNonNull(trigger, Required.TRIGGER.toString());
        Objects.requireNonNull(this.quartzScheduler, Required.SCHEDULER.toString());

        try {
            this.quartzScheduler.scheduleJob(jobDetail, trigger);
        } catch (final SchedulerException e) {
            throw new MangooSchedulerException(e);
        }
    }
357977
public static Timer schedule(
            TimeoutHandler timeoutHandler, Instant scheduledFor) {
        return scheduler.schedule(timeoutHandler, scheduledFor);
    }
106994
protected function defineConsoleSchedule()
    {
        $this->app->singleton(Schedule::class, function ($app) {
            return new Schedule();
        });

        $schedule = $this->app->make(Schedule::class);

        $this->schedule($schedule);
    }
551074
public Project.Calendars.Calendar.WorkWeeks.WorkWeek.WeekDays createProjectCalendarsCalendarWorkWeeksWorkWeekWeekDays()
   {
      return new Project.Calendars.Calendar.WorkWeeks.WorkWeek.WeekDays();
   }
758998
boolean schedule(Runnable task,
                   ClassLoader loader,
                   long timeout)
  {
    return schedule(new RunnableItem(task, loader, timeout));
  }
542815
public SchedulerDriver createDriver(Scheduler scheduler, boolean implicitAcknowledgements) {
		MesosSchedulerDriver schedulerDriver;
		if (this.credential().isDefined()) {
			schedulerDriver =
				new MesosSchedulerDriver(scheduler, frameworkInfo.build(), this.masterUrl(),
					implicitAcknowledgements, this.credential().get().build());
		}
		else {
			schedulerDriver =
				new MesosSchedulerDriver(scheduler, frameworkInfo.build(), this.masterUrl(),
					implicitAcknowledgements);
		}
		return schedulerDriver;
	}
333476
public Project.Calendars.Calendar.Exceptions.Exception.TimePeriod createProjectCalendarsCalendarExceptionsExceptionTimePeriod()
   {
      return new Project.Calendars.Calendar.Exceptions.Exception.TimePeriod();
   }
672609
public Project.Calendars.Calendar.Exceptions.Exception createProjectCalendarsCalendarExceptionsException()
   {
      return new Project.Calendars.Calendar.Exceptions.Exception();
   }
843500
def create_task(self, ):
        
        depi = self.dep_cb.currentIndex()
        assert depi >= 0
        dep = self.deps[depi]
        deadline = self.deadline_de.dateTime().toPython()
        try:
            task = djadapter.models.Task(department=dep, project=self.element.project, element=self.element, deadline=deadline)
            task.save()
            self.task = task
            self.accept()
        except:
            log.exception("Could not create new task")
760892
public Config createAdaptorRuntime(SchedulerStateManagerAdaptor adaptor) {
    return Config.newBuilder()
        .put(Key.SCHEDULER_STATE_MANAGER_ADAPTOR, adaptor).build();
  }
1039393
public Project.Calendars.Calendar.Exceptions.Exception.WorkingTimes createProjectCalendarsCalendarExceptionsExceptionWorkingTimes()
   {
      return new Project.Calendars.Calendar.Exceptions.Exception.WorkingTimes();
   }
502163
def create(self):
        
        self.queue = self.scheduler.queue.addSubQueue(self.priority, LockEvent.createMatcher(self.context, self.key),
                                         maxdefault = self.size, defaultQueueClass = CBQueue.AutoClassQueue.initHelper('locker', subqueuelimit = 1))
1261652
@Override
    public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {
        ScheduledExecutorService executor = getScheduledExecutor();
        try {
            ErrorHandler errorHandlerLocal = this.errorHandler != null ? this.errorHandler : TaskUtils
                    .getDefaultErrorHandler(true);
            return new ReschedulingRunnable(task, trigger, executor, errorHandlerLocal).schedule();
        } catch (RejectedExecutionException ex) {
            throw new TaskRejectedException("Executor [" + executor + "] did not accept task: " + task, ex);
        }
    }
1251415
ScheduledExecutorService createSchedulerExecutor(final String prefix) {
		ThreadFactory threadFactory = new ThreadFactory() {
			private int counter = 0;
			@Override
			public Thread newThread(Runnable runnable) {
				return new Thread(runnable, prefix + ++counter);
			}
		};
		ScheduledExecutorService executor = java.util.concurrent.Executors.newSingleThreadScheduledExecutor(threadFactory);
		return executor;
	}
400986
public TimerTask newTimerTask(TimerTaskData data) {
		if (scheduler == null) {
			throw new IllegalStateException("unable to create data, scheduler is not set");
		}
		return new FaultTolerantTimerTimerTask((FaultTolerantTimerTimerTaskData) data,scheduler);
	}
934076
public ScheduleDescriptor generateScheduleDescriptor(LocalDate startDate, LocalDate endDate) {
		return new ScheduleDescriptor(startDate, endDate, getFrequency(), getDaycountConvention(), getShortPeriodConvention(), getDateRollConvention(),
				getBusinessdayCalendar(), getFixingOffsetDays(), getPaymentOffsetDays(), isUseEndOfMonth());
	}