diff --git a/ckanext/validation/plugin/__init__.py b/ckanext/validation/plugin/__init__.py
index 2b6efeea..d6dbd39b 100644
--- a/ckanext/validation/plugin/__init__.py
+++ b/ckanext/validation/plugin/__init__.py
@@ -155,19 +155,15 @@ def _process_schema_fields(self, data_dict):
 
         return data_dict
 
-    if ckan_2_10:
-        def before_resource_create(self, context, data_dict):
+    def before_resource_create(self, context, data_dict):
 
-            context["_resource_create_call"] = True
-            return self._process_schema_fields(data_dict)
+        context["_resource_create_call"] = True
+        return self._process_schema_fields(data_dict)
             
-    else: 
-        def before_create(self, context, data_dict):
+    def before_create(self, context, data_dict):
 
-            is_dataset = self._data_dict_is_dataset(data_dict)
-            if not is_dataset:
-                context["_resource_create_call"] = True
-                return self._process_schema_fields(data_dict)
+        if not self._data_dict_is_dataset(data_dict):
+            return self.before_resource_create(context, data_dict)
 
     def after_create(self, context, data_dict):