Skip to content

Commit

Permalink
Merge pull request #2207 from deniszh/DZ-whisper-now-fix
Browse files Browse the repository at this point in the history
Propagate `now` parameter for whisper reader
  • Loading branch information
deniszh committed Jan 17, 2018
2 parents ded6a2d + b09887e commit 84a3020
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions webapp/graphite/readers/whisper.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,12 +51,12 @@ def get_intervals(self):
end = max(stat(self.fs_path).st_mtime, start)
return IntervalSet([Interval(start, end)])

def fetch_data(self, startTime, endTime):
return whisper.fetch(self.fs_path, startTime, endTime)
def fetch_data(self, startTime, endTime, now=None):
return whisper.fetch(self.fs_path, startTime, endTime, now=now)

def fetch(self, startTime, endTime):
def fetch(self, startTime, endTime, now=None, requestContext=None):
try:
data = self.fetch_data(startTime, endTime)
data = self.fetch_data(startTime, endTime, now=now)
except IOError:
log.exception("Failed fetch of whisper file '%s'" % self.fs_path)
return None
Expand Down Expand Up @@ -88,9 +88,9 @@ def info(self):
fh.close()
return self.meta_info

def fetch_data(self, startTime, endTime):
def fetch_data(self, startTime, endTime, now=None):
fh = gzip.GzipFile(self.fs_path, 'rb')
try:
return whisper.file_fetch(fh, startTime, endTime)
return whisper.file_fetch(fh, startTime, endTime, now=now)
finally:
fh.close()

0 comments on commit 84a3020

Please sign in to comment.