The test should wait until the worker leader is ready, otherwise the …

…request to create function will fail (apache#7507)

* The test should wait until the worker leader is ready, otherwise the request to create function will fail

* Moved to test setup

pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java

@@ -293,6 +293,10 @@ && isNotBlank(workerConfig.getBrokerClientAuthenticationParameters())) {
         });
         fileServerThread.start();
         latch.await(1, TimeUnit.SECONDS);
+
+        functionsWorkerService.getLeaderService().waitLeaderInit();
+
+
     }
 
     @AfterMethod
@@ -1493,7 +1497,6 @@ public void testPulsarFunctionStatus() throws Exception {
 
     @Test(dataProvider = "validRoleName")
     public void testAuthorization(boolean validRoleName) throws Exception {
-
         final String namespacePortion = "io";
         final String replNamespace = tenant + "/" + namespacePortion;
         final String sinkTopic = "persistent://" + replNamespace + "/output";