Accelerate the task

REST: POST /me/task/domain/{id}/accelerate
@param id [required] Id of the task
979105
public void task_domain_id_accelerate_POST(Long id) throws IOException {
		String qPath = "/me/task/domain/{id}/accelerate";
		StringBuilder sb = path(qPath, id);
		exec(qPath, "POST", sb.toString(), null);
	}
1180865
function run (task, runId)
{
	if (task._runId !== runId)
		return;
	
	var delay = Math.max(0, task.nextEvent.getTime() - Date.now());
	task._timeout = setTimeout(executeTask, delay, task, runId);
	if (task._unref)
		task._timeout.unref();
}
76653
def load_post(wp_post_id):
    

    # wait a bit to give WordPress REST API a chance to catch up
    time.sleep(1)

    loader = WPAPILoader()
    post = loader.load_post(wp_post_id)

    if post:
        logger.info("Successfully loaded post wp_post_id=%s, pk=%s", wp_post_id, post.pk)
    else:
        logger.warning("Error loading post wp_post_id=%s", wp_post_id)
753554
public void runDecider(String workflowId) {
        Preconditions.checkArgument(StringUtils.isNotBlank(workflowId), "workflow id cannot be blank");
        stub.decideWorkflow(WorkflowServicePb.DecideWorkflowRequest.newBuilder()
                .setWorkflowId(workflowId)
                .build()
        );
    }
253237
public void accessRestriction_totp_id_PUT(Long id, OvhTOTPAccount body) throws IOException {
		String qPath = "/me/accessRestriction/totp/{id}";
		StringBuilder sb = path(qPath, id);
		exec(qPath, "PUT", sb.toString(), body);
	}
1141932
public static void delete(final String id) throws AppPlatformException, IOException {
        assert(id != null);
        final BandwidthClient client = BandwidthClient.getInstance();
        client.delete(client.getUserResourceInstanceUri(BandwidthConstants.DOMAINS_URI_PATH, id));
    }
1087547
public OvhTaskMl domain_task_mailinglist_id_GET(String domain, Long id) throws IOException {
		String qPath = "/email/domain/{domain}/task/mailinglist/{id}";
		StringBuilder sb = path(qPath, domain, id);
		String resp = exec(qPath, "GET", sb.toString(), null);
		return convertTo(resp, OvhTaskMl.class);
	}
370318
public void project_serviceName_ipLoadbalancing_id_validate_POST(String serviceName, String id) throws IOException {
		String qPath = "/cloud/project/{serviceName}/ipLoadbalancing/{id}/validate";
		StringBuilder sb = path(qPath, serviceName, id);
		exec(qPath, "POST", sb.toString(), null);
	}
237615
def on_before_publish_insert_request_id_header(headers, **kwargs):
    
    if _CELERY_X_HEADER not in headers:
        request_id = current_request_id()
        headers[_CELERY_X_HEADER] = request_id
        logger.debug("Forwarding request_id '{}' to the task consumer.".format(request_id))
824523
protected void enableApiKeyInternal(final ObjectId id) {
    final StitchAuthRequest.Builder reqBuilder = new StitchAuthRequest.Builder();
    reqBuilder
            .withMethod(Method.PUT)
            .withPath(routes.getApiKeyEnableRouteForId(id.toHexString()))
            .withRefreshToken();
    getRequestClient().doAuthenticatedRequest(reqBuilder.build());
  }
814454
def task_progress(task_or_id)
      task_id = task_or_id.is_a?(Hash) ? task_or_id['id'] : task_or_id
      if !task_id.empty?
        options = { verbosity: @context[:verbosity] || HammerCLI::V_VERBOSE }
        task_progress = TaskProgress.new(task_id, options) { |id| load_task(id) }
        task_progress.render
        task_progress.success?
      else
        signal_usage_error(_('Please mention appropriate attribute value'))
      end
    end
1098094
@DELETE
    @Path("/{id}")
    public Response delete(@PathParam("id") final String id)
            throws IOException {
        return execute(getResourceRequest(RequestTypeEnum.DELETE, RestOperationTypeEnum.DELETE).id(id));
    }
908716
public void setId(String id)
	{
		if (id == null || id.length() == 0)
			throw new IllegalArgumentException(
			"id required in setId");

		this.setId(Integer.valueOf(id));
	}
996811
public void postEdit(String blogName, Long id, Map<String, ?> detail) throws IOException {
        Map<String, Object> sdetail = JumblrClient.safeOptionMap(detail);
        sdetail.put("id", id);
        requestBuilder.postMultipart(JumblrClient.blogPath(blogName, "/post/edit"), sdetail);
    }
633101
@Override
    public PageException execute(String id) {
	SpoolerTask task = getTaskById(openDirectory, id);
	if (task == null) task = getTaskById(closedDirectory, id);
	if (task != null) {
	    return execute(task);
	}
	return null;
    }
1138192
public JSONObject updateTask(int id, HashMap<String, String> options) {
        AipRequest request = new AipRequest();
        preOperation(request);
        
        request.addBody("id", id);
        if (options != null) {
            request.addBody(options);
        }
        request.setUri(KnowledgeGraphicConsts.UPDATE_TASK);
        postOperation(request);
        return requestServer(request);
    }
764881
public static void validateServiceInstanceID(String id) throws ServiceException {
        if (!validateRequiredField(id, idRegEx)) {
            throw new ServiceException(
                    ErrorCode.SERVICE_INSTANCE_ID_FORMAT_ERROR);
        }
    }