diff --git a/integration/test/IdempotencyTest.js b/integration/test/IdempotencyTest.js
index d8c546133..cb834bd4d 100644
--- a/integration/test/IdempotencyTest.js
+++ b/integration/test/IdempotencyTest.js
@@ -35,8 +35,8 @@ describe('Idempotency', () => {
   it('handle duplicate job request', async () => {
     DuplicateRequestId('1234');
     const params = { startedBy: 'Monty Python' };
-    const jobStatusId = await Parse.Cloud.startJob('CloudJob1', params);
-    await expectAsync(Parse.Cloud.startJob('CloudJob1', params)).toBeRejectedWithError(
+    const jobStatusId = await Parse.Cloud.startJob('CloudJobParamsInMessage', params);
+    await expectAsync(Parse.Cloud.startJob('CloudJobParamsInMessage', params)).toBeRejectedWithError(
       'Duplicate request'
     );
 
@@ -49,7 +49,7 @@ describe('Idempotency', () => {
     }
     const jobStatus = await Parse.Cloud.getJobStatus(jobStatusId);
     expect(jobStatus.get('status')).toBe('succeeded');
-    expect(jobStatus.get('params').startedBy).toBe('Monty Python');
+    expect(JSON.parse(jobStatus.get('message'))).toEqual(params);
   });
 
   it('handle duplicate POST / PUT request', async () => {
diff --git a/integration/test/ParseCloudTest.js b/integration/test/ParseCloudTest.js
index c4704d00c..57d7db96d 100644
--- a/integration/test/ParseCloudTest.js
+++ b/integration/test/ParseCloudTest.js
@@ -95,13 +95,13 @@ describe('Parse Cloud', () => {
 
   it('run job', async () => {
     const params = { startedBy: 'Monty Python' };
-    const jobStatusId = await Parse.Cloud.startJob('CloudJob1', params);
+    const jobStatusId = await Parse.Cloud.startJob('CloudJobParamsInMessage', params);
     expect(jobStatusId).toBeDefined();
     await waitForJobStatus(jobStatusId, 'succeeded');
 
     const jobStatus = await Parse.Cloud.getJobStatus(jobStatusId);
-    assert.equal(jobStatus.get('status'), 'succeeded');
-    assert.equal(jobStatus.get('params').startedBy, 'Monty Python');
+    expect(jobStatus.get('status')).toBe('succeeded');
+    expect(JSON.parse(jobStatus.get('message'))).toEqual(params);
   });
 
   it('run long job', async () => {
@@ -137,7 +137,7 @@ describe('Parse Cloud', () => {
   it('get jobs data', done => {
     Parse.Cloud.getJobsData().then(result => {
       assert.equal(result.in_use.length, 0);
-      assert.equal(result.jobs.length, 3);
+      assert.equal(result.jobs.length, 4);
       done();
     });
   });
diff --git a/integration/test/cloud/main.js b/integration/test/cloud/main.js
index 920948d83..8641dda41 100644
--- a/integration/test/cloud/main.js
+++ b/integration/test/cloud/main.js
@@ -45,6 +45,10 @@ Parse.Cloud.job('CloudJob2', function () {
   });
 });
 
+Parse.Cloud.job('CloudJobParamsInMessage', request => {
+  request.message(JSON.stringify(request.params));
+});
+
 Parse.Cloud.job('CloudJobFailing', function () {
   throw 'cloud job failed';
 });
diff --git a/integration/test/helper.js b/integration/test/helper.js
index 0bd7fb10a..46a257372 100644
--- a/integration/test/helper.js
+++ b/integration/test/helper.js
@@ -74,7 +74,7 @@ const defaultConfiguration = {
     },
   },
   idempotencyOptions: {
-    paths: ['functions/CloudFunctionIdempotency', 'jobs/CloudJob1', 'classes/IdempotentTest'],
+    paths: ['functions/CloudFunctionIdempotency', 'jobs/CloudJob1', 'jobs/CloudJobParamsInMessage', 'classes/IdempotentTest'],
     ttl: 120,
   },
   fileUpload: {