[v1alpha2]update tfjob condition for Created (kubeflow#694)

* [v1alpha2]update tfjob condition for Created

* update ci

pkg/controller.v2/controller_tfjob.go

@@ -43,6 +43,12 @@ func (tc *TFJobController) addTFJob(obj interface{}) {
 		return
 	}
 
+	// Convert from tfjob object
+	err = unstructuredFromTFJob(obj, tfJob)
+	if err != nil {
+		log.Error("Failed to convert the obj: %v", err)
+		return
+	}
 	tc.enqueueTFJob(obj)
 }
 

pkg/controller.v2/informer.go

@@ -97,3 +97,20 @@ func tfJobFromUnstructured(obj interface{}) (*tfv1alpha2.TFJob, error) {
 	}
 	return &tfjob, nil
 }
+
+func unstructuredFromTFJob(obj interface{}, tfJob *tfv1alpha2.TFJob) error {
+	un, ok := obj.(*metav1unstructured.Unstructured)
+	if !ok {
+		log.Warn("The objetc in index is not an unstructured")
+		return errGetFromKey
+	}
+
+	var err error
+	un.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(tfJob)
+	if err != nil {
+		log.Error("The TFJob connvert failed")
+		return err
+	}
+	return nil
+
+}