Skip to content

Commit 7f30683

Browse files
* BUGFIX: Fixed CLI bug
2 parents f8373fd + 3798224 commit 7f30683

File tree

2 files changed

+21
-7
lines changed

2 files changed

+21
-7
lines changed

src/iotswarm/devices.py

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,14 @@
44
import logging
55
from iotswarm import __version__ as package_version
66
from iotswarm.queries import CosmosTable
7-
from iotswarm.db import BaseDatabase, CosmosDB, Oracle, LoopingCsvDB, LoopingSQLite3
7+
from iotswarm.db import (
8+
BaseDatabase,
9+
MockDB,
10+
CosmosDB,
11+
Oracle,
12+
LoopingCsvDB,
13+
LoopingSQLite3,
14+
)
815
from iotswarm.messaging.core import MessagingBaseClass, MockMessageConnection
916
from iotswarm.messaging.aws import IotCoreMQTTConnection
1017
from typing import List
@@ -306,8 +313,11 @@ async def run(self):
306313
)
307314
self.cycle += 1
308315

309-
if self.swarm is not None:
310-
self.swarm.write_self(replace=True)
316+
if isinstance(
317+
self.data_source, (LoopingCsvDB, LoopingSQLite3, MockDB)
318+
):
319+
if self.swarm is not None:
320+
self.swarm.write_self(replace=True)
311321
else:
312322
self._instance_logger.warning(f"No data found.")
313323

src/iotswarm/scripts/cli.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -303,8 +303,10 @@ async def _mqtt_resume_session():
303303

304304
for i in range(len(swarm.devices)):
305305
swarm.devices[i].connection = connection
306-
swarm.devices[i].max_cycles = max_cycles
307-
swarm.devices[i].sleep_time = sleep_time
306+
if max_cycles is not None:
307+
swarm.devices[i].max_cycles = max_cycles
308+
if sleep_time is not None:
309+
swarm.devices[i].sleep_time = sleep_time
308310

309311
click.echo("Loaded swarm from pickle")
310312

@@ -452,8 +454,10 @@ async def _mqtt_resume_session():
452454

453455
for i in range(len(swarm.devices)):
454456
swarm.devices[i].connection = connection
455-
swarm.devices[i].max_cycles = max_cycles
456-
swarm.devices[i].sleep_time = sleep_time
457+
if max_cycles is not None:
458+
swarm.devices[i].max_cycles = max_cycles
459+
if sleep_time is not None:
460+
swarm.devices[i].sleep_time = sleep_time
457461

458462
click.echo(swarm.devices[0].cycle)
459463
click.echo("Loaded swarm from pickle")

0 commit comments

Comments
 (0)