@@ -201,6 +201,7 @@ def __init__(
201
201
self ._heartbeat_thread : threading .Thread | None = None
202
202
203
203
self ._heartbeat_interval : int = HEARTBEAT_INTERVAL
204
+ self ._emissions_monitor : CO2Monitor | None = None
204
205
self ._emission_metrics_interval : int | None = (
205
206
HEARTBEAT_INTERVAL
206
207
if (
@@ -209,28 +210,6 @@ def __init__(
209
210
)
210
211
else self ._user_config .metrics .emission_metrics_interval
211
212
)
212
- if mode == "offline" :
213
- if not (_co2_intensity := self ._user_config .eco .co2_intensity ):
214
- self ._error (
215
- "Cannot record emission metrics, "
216
- "a CO2 intensity value is required in offline mode."
217
- )
218
- # Create an emissions monitor with no API calls
219
- self ._emissions_monitor = CO2Monitor (
220
- intensity_refresh_rate = None ,
221
- co2_intensity = _co2_intensity ,
222
- local_data_directory = self ._user_config .eco .local_data_directory ,
223
- co2_signal_api_token = None ,
224
- cpu_idle_power = self ._user_config .eco .cpu_idle_power ,
225
- )
226
- else :
227
- self ._emissions_monitor = CO2Monitor (
228
- intensity_refresh_rate = self ._user_config .eco .intensity_refresh_rate ,
229
- local_data_directory = self ._user_config .eco .local_data_directory ,
230
- co2_signal_api_token = self ._user_config .eco .co2_signal_api_token ,
231
- cpu_idle_power = self ._user_config .eco .cpu_idle_power ,
232
- co2_intensity = self ._user_config .eco .co2_intensity ,
233
- )
234
213
235
214
def __enter__ (self ) -> Self :
236
215
return self
0 commit comments