Skip to content

Commit

Permalink
Forest Model related data additions
Browse files Browse the repository at this point in the history
While testing model integration, 2 forest model features specific features are added in the `TestForestModelIntegration.py` file rather than in `entry.py` file.
  • Loading branch information
humbleOldSage committed Mar 21, 2024
1 parent 1b523ed commit 35a1346
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
3 changes: 0 additions & 3 deletions emission/core/wrapper/entry.py
Original file line number Diff line number Diff line change
Expand Up @@ -182,9 +182,6 @@ def create_fake_entry(user_id, key, data, write_ts, create_id=False):
result_entry.user_id = user_id
result_entry.metadata = ecwm.Metadata.create_metadata_for_fake_result(key, write_ts)
result_entry.data = data
#necessary values required by forest model
result_entry['data']['start_local_dt']=result_entry['metadata']['write_local_dt']
result_entry['data']['end_local_dt']=result_entry['metadata']['write_local_dt']
result_entry._populateDependencies()
return result_entry

Expand Down
5 changes: 5 additions & 0 deletions emission/tests/modellingTests/TestForestModelIntegration.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,11 @@ def setUp(self):
threshold=0.004, # ~400m
has_label_p=0.9
)

for result_entry in train:
result_entry['data']['start_local_dt']=result_entry['metadata']['write_local_dt']
result_entry['data']['end_local_dt']=result_entry['metadata']['write_local_dt']

ts.bulk_insert(train)
# confirm data write did not fail
check_data = esda.get_entries(key="analysis/confirmed_trip", user_id=self.testUUID, time_query=None)
Expand Down
2 changes: 0 additions & 2 deletions emission/tests/modellingTests/TestRunForestModel.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,6 @@
import emission.analysis.modelling.trip_model.model_type as eamumt
import emission.analysis.modelling.trip_model.model_storage as eamums
import emission.analysis.modelling.trip_model.models as eamtm
logger=logging.getLogger("")
logger.setLevel(logging.DEBUG)
import emission.storage.timeseries.abstract_timeseries as esta
import emission.tests.modellingTests.modellingTestAssets as etmm
import emission.storage.decorations.analysis_timeseries_queries as esda
Expand Down

0 comments on commit 35a1346

Please sign in to comment.