Skip to content

Commit 1d7111d

Browse files
committed
fix: 修复节点没有上线的问题
1 parent 7966d1e commit 1d7111d

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

core/cluster.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -448,8 +448,8 @@ async def start(self):
448448

449449
# start job
450450

451-
#for cluster in self.clusters:
452-
# await cluster.enable()
451+
for cluster in self.clusters:
452+
await cluster.enable()
453453

454454
def get_cluster_by_id(self, id: Optional[str] = None) -> Optional['Cluster']:
455455
return self.cluster_id_tables.get(id or "", None)
@@ -614,7 +614,6 @@ async def keepalive(self):
614614
await self.disable()
615615
return
616616
self.counter -= commit_counter
617-
logger.debug(result.ack)
618617
timestamp = utils.parse_isotime_to_timestamp(result.ack)
619618
ping = (time.time() - timestamp) // 0.0002
620619
logger.tsuccess("cluster.success.keepalive", cluster=self.id, hits=units.format_number(commit_counter.hits), bytes=units.format_bytes(commit_counter.bytes), ping=ping)

0 commit comments

Comments
 (0)