Merge pull request #459 from DataIntegrationGroup/BDMS-520-1-1-Cleanup-2.0

jirhiker · web-flow · commit ad213794844b · 2026-02-02T09:01:48.000+11:00
BDMS-520-1-1-Cleanup-2.0
diff --git a/transfers/waterlevels_transducer_transfer.py b/transfers/waterlevels_transducer_transfer.py
@@ -259,8 +259,10 @@ def _get_or_create_block(
                 TransducerObservationBlock.thing_id == block.thing_id,
                 TransducerObservationBlock.parameter_id == block.parameter_id,
                 TransducerObservationBlock.review_status == block.review_status,
-                TransducerObservationBlock.start_datetime == block.start_datetime,
-                TransducerObservationBlock.end_datetime == block.end_datetime,
+                TransducerObservationBlock.start_datetime
+                == Timestamp(block.start_datetime),
+                TransducerObservationBlock.end_datetime
+                == Timestamp(block.end_datetime),
             )
             .one_or_none()
         )

Original file line number	Diff line number	Diff line change
`@@ -259,8 +259,10 @@ def _get_or_create_block(`
`259`	`259`	`TransducerObservationBlock.thing_id == block.thing_id,`
`260`	`260`	`TransducerObservationBlock.parameter_id == block.parameter_id,`
`261`	`261`	`TransducerObservationBlock.review_status == block.review_status,`
`262`		`- TransducerObservationBlock.start_datetime == block.start_datetime,`
`263`		`- TransducerObservationBlock.end_datetime == block.end_datetime,`
	`262`	`+ TransducerObservationBlock.start_datetime`
	`263`	`+ == Timestamp(block.start_datetime),`
	`264`	`+ TransducerObservationBlock.end_datetime`
	`265`	`+ == Timestamp(block.end_datetime),`
`264`	`266`	`)`
`265`	`267`	`.one_or_none()`
`266`	`268`	`)`