const int num_inputs = input_shapes->num_items;
  NodeDef node_def;
  tensorflow::ImmediateExecutionOperation* op = tensorflow::unwrap(tfe_op);
  node_def.set_name(op->Name());
  node_def.set_op(op->Name());
  for (int i = 0; i < num_inputs; ++i) {
    node_def.add_input("dummy_input");
  }
  OperationFromInterface(op)->Attrs().FillAttrValueMap(node_def.mutable_attr());

    @Override
    public Plugin getPluginDefinitionForPrefix(String prefix, MavenSession session, MavenProject project) {
        PluginPrefixRequest request = new DefaultPluginPrefixRequest(prefix, session);
        request.setPom(project.getModel());

        try {
            PluginPrefixResult result = pluginPrefixResolver.resolve(request);

            Plugin plugin = new Plugin();
            plugin.setGroupId(result.getGroupId());

            RenderDataUtil.register(data, "scheduledJobItems", scheduledJobService.getScheduledJobList(schedulerPager)); // page navi
        }).useForm(SearchForm.class, setup -> {
            setup.setup(form -> {
                copyBeanToBean(schedulerPager, form, op -> op.include("id"));
            });
        });
    }

    private HtmlResponse asEditHtml() {

/**
 * @author shinsuke
 *
 */
public class HcHttpClientTest extends PlainTestCase {
    public HcHttpClient httpClient;

    public UrlFilter urlFilter;

    @Override
    protected void setUp() throws Exception {
        super.setUp();
        StandardCrawlerContainer container = new StandardCrawlerContainer().singleton("mimeTypeHelper", MimeTypeHelperImpl.class)//
                .singleton("dataHelper", MemoryDataHelper.class)//

      assertEquals(200, response.code)
      assertEquals(Protocol.HTTP_2, response.protocol)
    }

    // Only logs to the test logger above
    // Will fail if "adb shell setprop log.tag.okhttp.Http2 DEBUG" is called
    assertEquals(setOf(OkHttpTest::class.java.name), testHandler.calls.keys)
  }

  fun testCachedRequest() {
    enableTls()

		return nil, setupType, err
	}

	_, serverAddrPort := mustSplitHostPort(serverAddr)

	poolEndpoints := make(PoolEndpointList, len(poolsLayout))

	// For single arg, return single drive EC setup.
	if isSingleDriveLayout(poolsLayout...) {
		endpoint, err := NewEndpoint(poolsLayout[0].layout[0][0])
		if err != nil {
			return nil, setupType, err
		}
		if err := endpoint.UpdateIsLocal(); err != nil {

    @Override
    public void setUp() throws Exception {
        super.setUp();
        aggregateLogJob = new AggregateLogJob();
    }

    public void test_constructor() {
        // Test default constructor
        AggregateLogJob job = new AggregateLogJob();
        assertNotNull(job);
    }

    public void test_execute_success() {
        // Setup mock SearchLogHelper that succeeds

    private ScriptExecutor scriptExecutor;
    private ScriptEngineFactory scriptEngineFactory;
    private TestScriptEngine testScriptEngine;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        scriptExecutor = new ScriptExecutor();
        scriptEngineFactory = new ScriptEngineFactory();
        testScriptEngine = new TestScriptEngine();

	./mc ready myminio
}

function test_resiliency_failure_with_servers_down() {
	echo
	echo -e "${GREEN}Running test_resiliency_failure_with_servers_down ...${NC}"
	# Stop two nodes
	docker stop resiliency-minio1-1
	docker stop resiliency-minio2-1
	sleep 10

	verify_resiliency_failure "${FUNCNAME[0]}"

	# Restart the nodes
	docker start resiliency-minio1-1
	docker start resiliency-minio2-1

public class FessUserLocaleProcessProviderTest extends UnitFessTestCase {

    private FessUserLocaleProcessProvider provider;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        provider = new FessUserLocaleProcessProvider();
    }

    @Override
    public void tearDown() throws Exception {
        ComponentUtil.setFessConfig(null);
        super.tearDown();