code: public static Duration getLeadTimeDurationFromConfig(State state) {
      String leadTimeProp = state.getProp(DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME);
      if (leadTimeProp == null || leadTimeProp.length() == 0) {
        return DEFAULT_PARTITIONED_SOURCE_PARTITION_LEAD_TIME;
      }
  
      int leadTime = Integer.parseInt(leadTimeProp);
  
      DatePartitionType leadTimeGranularity = DEFAULT_DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY;
  
      String leadTimeGranularityProp = state.getProp(DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY);
      if (leadTimeGranularityProp != null) {
        leadTimeGranularity = DatePartitionType.valueOf(leadTimeGranularityProp);
      }
  
      return new Duration(leadTime * leadTimeGranularity.getUnitMilliseconds());
    }
docs: Retrieve the lead time duration from the LEAD_TIME and LEAD_TIME granularity config settings.