diff --git a/autosubmit/platforms/headers/ec_cca_header.py b/autosubmit/platforms/headers/ec_cca_header.py
index b0b85b7bf0935c91402336902b51c2ef852f8e6d..0105520afc97a897b7ca87bbf01a9bb18bc5b326 100644
--- a/autosubmit/platforms/headers/ec_cca_header.py
+++ b/autosubmit/platforms/headers/ec_cca_header.py
@@ -41,7 +41,7 @@ class EcCcaHeader(object):
             else:
                 queue = 'np'
 
-        return "PBS -q {0}".format(job.parameters['CURRENT_QUEUE'])
+        return "PBS -q {0}".format(queue)
 
     # noinspection PyMethodMayBeStatic
     def get_tasks_per_node(self, job):