diff --git a/welco/utils.py b/welco/utils.py
index 549da18..9acf3d3 100644
--- a/welco/utils.py
+++ b/welco/utils.py
@@ -113,9 +113,13 @@ def push_wcs_formdata(request, formdef_reference, context=None):
     wcs_site_url = get_wcs_services()[wcs_key]['url']
     if not wcs_site_url.endswith('/'):
         wcs_site_url += '/'
+    url = wcs_site_url + 'api/formdefs/%s/schema' % form_slug
+    response = requests.get(url)
+    create_draft = not(bool('welco-direct' in response.json().get('keywords', '')))
+
     url = wcs_site_url + 'api/formdefs/%s/submit?' % form_slug
     data = {
-        'meta': {'draft': True, 'backoffice-submission': True},
+        'meta': {'draft': create_draft, 'backoffice-submission': True},
         'data': {},
     }
     if context: