Timofei Efimov tefimov

Table Of Content

Skip to the relevant sections if needed.

	# -- coding: utf-8 --
	"""
	celery.contrib.batches
	======================
	Experimental task class that buffers messages and processes them as a list.
	.. warning::
	For this to work you have to set
	:setting:`CELERYD_PREFETCH_MULTIPLIER` to zero, or some value where
	the final multiplied value is higher than ``flush_every``.
	In the future we hope to add the ability to direct batching tasks

	import numpy as np
	import pylab as pl
	from numpy import fft

	def fourierExtrapolation(x, n_predict):
	n = x.size
	n_harm = 10 # number of harmonics in model
	t = np.arange(0, n)
	p = np.polyfit(t, x, 1) # find linear trend in x
	x_notrend = x - p[0] * t # detrended x