Spaces:
Sleeping
Sleeping
revert inference code
Browse files- tasks/utils/emissions.py +5 -36
tasks/utils/emissions.py
CHANGED
@@ -1,13 +1,8 @@
|
|
1 |
-
# tasks/utils/emissions.py
|
2 |
from codecarbon import EmissionsTracker
|
3 |
import os
|
4 |
|
5 |
-
# Initialize tracker
|
6 |
-
tracker = EmissionsTracker(
|
7 |
-
project_name="frugal-ai-challenge",
|
8 |
-
output_dir=".",
|
9 |
-
log_level='warning'
|
10 |
-
)
|
11 |
|
12 |
class EmissionsData:
|
13 |
def __init__(self, energy_consumed: float, emissions: float):
|
@@ -16,15 +11,8 @@ class EmissionsData:
|
|
16 |
|
17 |
def clean_emissions_data(emissions_data):
|
18 |
"""Remove unwanted fields from emissions data"""
|
19 |
-
|
20 |
-
|
21 |
-
else:
|
22 |
-
data_dict = emissions_data.__dict__
|
23 |
-
|
24 |
-
fields_to_remove = [
|
25 |
-
'timestamp', 'project_name', 'experiment_id',
|
26 |
-
'latitude', 'longitude', '_start_time', '_end_time'
|
27 |
-
]
|
28 |
return {k: v for k, v in data_dict.items() if k not in fields_to_remove}
|
29 |
|
30 |
def get_space_info():
|
@@ -37,23 +25,4 @@ def get_space_info():
|
|
37 |
return username, space_url
|
38 |
except Exception as e:
|
39 |
print(f"Error getting space info: {e}")
|
40 |
-
return "local-user", "local-development"
|
41 |
-
|
42 |
-
def start_tracking():
|
43 |
-
"""Start tracking emissions"""
|
44 |
-
try:
|
45 |
-
tracker.start()
|
46 |
-
except Exception as e:
|
47 |
-
print(f"Error starting emissions tracking: {e}")
|
48 |
-
|
49 |
-
def stop_tracking():
|
50 |
-
"""Stop tracking emissions and return data"""
|
51 |
-
try:
|
52 |
-
emissions = tracker.stop()
|
53 |
-
return EmissionsData(
|
54 |
-
energy_consumed=emissions.energy_consumed,
|
55 |
-
emissions=emissions.emissions
|
56 |
-
)
|
57 |
-
except Exception as e:
|
58 |
-
print(f"Error stopping emissions tracking: {e}")
|
59 |
-
return EmissionsData(energy_consumed=0.0, emissions=0.0)
|
|
|
|
|
1 |
from codecarbon import EmissionsTracker
|
2 |
import os
|
3 |
|
4 |
+
# Initialize tracker
|
5 |
+
tracker = EmissionsTracker(allow_multiple_runs=True)
|
|
|
|
|
|
|
|
|
6 |
|
7 |
class EmissionsData:
|
8 |
def __init__(self, energy_consumed: float, emissions: float):
|
|
|
11 |
|
12 |
def clean_emissions_data(emissions_data):
|
13 |
"""Remove unwanted fields from emissions data"""
|
14 |
+
data_dict = emissions_data.__dict__
|
15 |
+
fields_to_remove = ['timestamp', 'project_name', 'experiment_id', 'latitude', 'longitude']
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
16 |
return {k: v for k, v in data_dict.items() if k not in fields_to_remove}
|
17 |
|
18 |
def get_space_info():
|
|
|
25 |
return username, space_url
|
26 |
except Exception as e:
|
27 |
print(f"Error getting space info: {e}")
|
28 |
+
return "local-user", "local-development"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|