### Question:
PodKillerTask implements MasterEnvironmentTask { @Override public long run(MasterEnvironmentContext context) { try { CoreV1Api api = getCoreApi(); LOG.debug("Terminating pods using selector {}", podSelector); api.deleteCollectionNamespacedPod(namespace, null, null, null, podSelector, null, null, null, null); LOG.debug("Pods termination completed"); } catch (IOException e) { LOG.warn("IO Exception raised when connecting to Kubernetes API server", e); } catch (ApiException e) { LOG.warn("API exception raised when trying to delete pods, code=" + e.getCode() + ", body=" + e.getResponseBody(), e); } return delayMillis; } PodKillerTask(String namespace, String podSelector, long delayMillis); @Override long run(MasterEnvironmentContext context);  }### Answer:
@Test public void test() { PodKillerTask task = new PodKillerTask("default", "cdap.container=preview", 1000); task.run(new MasterEnvironmentContext() { @Override public LocationFactory getLocationFactory() { throw new UnsupportedOperationException("LocationFactory is not supported"); } @Override public Map<String, String> getConfigurations() { return Collections.emptyMap(); } @Override public String[] getRunnableArguments(Class<? extends MasterEnvironmentRunnable> runnableClass, String... runnableArgs) { throw new UnsupportedOperationException("Master environment runnable execution is not supported"); } }); }