Worker Observer observe other workers via special table in Casssandra and temporary INSERT with TTL. On output you have current workerId, num in cluster and cluster size.
task_id text,
worker_id int,
PRIMARY KEY (task_id, worker_id)
) WITH compaction ={'class': 'LeveledCompactionStrategy'};```