Merge pull request #1771 from OpenC3/fix_sharding

Fix sharding
OpenC3 · Dec 17, 2024 · 6cbf4f0 · 6cbf4f0
2 parents 5ff0cb2 + 4fe70f0
commit 6cbf4f0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/openc3-cosmos-init/plugins/packages/openc3-cosmos-demo/targets/INST2/procedures/calendar.py b/openc3-cosmos-init/plugins/packages/openc3-cosmos-demo/targets/INST2/procedures/calendar.py
@@ -21,7 +21,7 @@
 )  # => {"name":"Mine", "color":"#4287f5", "scope":"DEFAULT", "updated_at":1698763720728596964}
 
 now = datetime.now(timezone.utc)
-start = datetime(now.year, now.month, now.day, now.hour + 1, 30, 00, 00, timezone.utc)
+start = now + timedelta(hours=1)
 stop = start + timedelta(hours=1)  # Stop plus 1hr
 act = create_timeline_activity("Mine", kind="reserve", start=start, stop=stop)
 print(act)  # =>

diff --git a/openc3/lib/openc3/operators/microservice_operator.rb b/openc3/lib/openc3/operators/microservice_operator.rb
@@ -43,6 +43,7 @@ def initialize
       @changed_microservices = {}
       @removed_microservices = {}
       @shard = ENV['OPENC3_SHARD'] || 0
+      @shard = @shard.to_i
     end
 
     def convert_microservice_to_process_definition(microservice_name, microservice_config)