Skip to content

Commit a6a1dec

Browse files
authored
Merge pull request #44 from tales42/43-extend-time-bucket-arguments
Add support for offset and origin on TimeBucket
2 parents fbf4583 + abc7377 commit a6a1dec

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

timescale/db/models/expressions.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,11 +44,19 @@ class TimeBucket(models.Func):
4444
function = "time_bucket"
4545
name = "time_bucket"
4646

47-
def __init__(self, expression, interval, *args, **kwargs):
47+
48+
def __init__(self, expression, interval, offset=None, origin=None, *args, **kwargs):
4849
if not isinstance(interval, models.Value):
4950
interval = models.Value(interval)
51+
args = [interval, expression]
52+
if origin is not None:
53+
args.append(origin)
54+
elif offset is not None:
55+
if not isinstance(offset, models.Value):
56+
offset = models.Value(offset)
57+
args.append(offset)
5058
output_field = TimescaleDateTimeField(interval=interval)
51-
super().__init__(interval, expression, output_field=output_field)
59+
super().__init__(*args, output_field=output_field)
5260

5361

5462
class TimeBucketNG(models.Func):

0 commit comments

Comments
 (0)