@Override
    public Runnable get() {
        if (currentRunnable == null && currentStep != null) {
            currentRunnable = createRunnable(currentStep, state);
        }
        return currentRunnable;
    }
@Test
    public void step_supplier_get_returns_same_step() throws Exception {
        HazelcastInstance node = createHazelcastInstance(getConfig());
        Data data = Accessors.getSerializationService(node).toData("data");
        MapOperation operation = new SetOperation("map", data, data);
        operation.setNodeEngine(Accessors.getNodeEngineImpl(node));
        operation.setPartitionId(1);
        operation.beforeRun();

        StepSupplier stepSupplier = new StepSupplier(operation);
        Runnable get1 = stepSupplier.get();
        Runnable get2 = stepSupplier.get();
        assertEquals(get1, get2);
    }