diff --git a/.kokoro/common.cfg b/.kokoro/common.cfg
index 6fa7e084d8..eda1fed587 100644
--- a/.kokoro/common.cfg
+++ b/.kokoro/common.cfg
@@ -12,7 +12,7 @@ build_file: "nodejs-docs-samples/.kokoro/trampoline.sh"
 # Configure the docker image for kokoro-trampoline.
 env_vars: {
     key: "TRAMPOLINE_IMAGE"
-    value: "gcr.io/cloud-devrel-kokoro-resources/node:8-user"
+    value: "gcr.io/cloud-devrel-kokoro-resources/node:10-user"
 }
 
 # Export XUnit test results for further analysis
diff --git a/appengine/analytics/app.js b/appengine/analytics/app.js
index 47ee3276c6..057318eb37 100644
--- a/appengine/analytics/app.js
+++ b/appengine/analytics/app.js
@@ -58,10 +58,7 @@ app.get('/', async (req, res, next) => {
       'Example label',
       '100'
     );
-    res
-      .status(200)
-      .send('Event tracked.')
-      .end();
+    res.status(200).send('Event tracked.').end();
   } catch (error) {
     // This sample treats an event tracking error as a fatal error. Depending
     // on your application's needs, failing to track an event may not be
diff --git a/appengine/building-an-app/update/test/server.test.js b/appengine/building-an-app/update/test/server.test.js
index a58b94f9f4..6d6cee83c1 100755
--- a/appengine/building-an-app/update/test/server.test.js
+++ b/appengine/building-an-app/update/test/server.test.js
@@ -23,12 +23,12 @@ const cwd = path.join(__dirname, '../');
 
 const requestObj = supertest(proxyquire(path.join(cwd, 'server'), {process}));
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
@@ -40,7 +40,7 @@ it('should send greetings', async () => {
   await requestObj
     .get('/')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(response.text, 'Hello from App Engine!');
     });
 });
@@ -49,7 +49,7 @@ it('should display form', async () => {
   await requestObj
     .get('/submit')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(
         response.text.includes('textarea name="message" placeholder="Message"'),
         true
@@ -64,7 +64,7 @@ it('should record message', async () => {
       message: 'sample-message',
     })
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(response.text, 'Thanks for your message!');
     });
 });
diff --git a/appengine/cloudsql/createTables.js b/appengine/cloudsql/createTables.js
index 4b19d65ae0..09667558c5 100644
--- a/appengine/cloudsql/createTables.js
+++ b/appengine/cloudsql/createTables.js
@@ -34,7 +34,7 @@ prompt.get(FIELDS, async (err, config) => {
 
   // Create the "visits" table
   try {
-    await knex.schema.createTable('visits', table => {
+    await knex.schema.createTable('visits', (table) => {
       table.increments();
       table.timestamp('timestamp');
       table.string('userIp');
diff --git a/appengine/cloudsql/server.js b/appengine/cloudsql/server.js
index 0b5b026a9b..f0174ca3a1 100644
--- a/appengine/cloudsql/server.js
+++ b/appengine/cloudsql/server.js
@@ -69,7 +69,7 @@ const insertVisit = (knex, visit) => {
  * @param {object} knex The Knex connection object.
  * @returns {Promise}
  */
-const getVisits = async knex => {
+const getVisits = async (knex) => {
   const results = await knex
     .select('timestamp', 'userIp')
     .from('visits')
@@ -77,7 +77,7 @@ const getVisits = async knex => {
     .limit(10);
 
   return results.map(
-    visit => `Time: ${visit.timestamp}, AddrHash: ${visit.userIp}`
+    (visit) => `Time: ${visit.timestamp}, AddrHash: ${visit.userIp}`
   );
 };
 
diff --git a/appengine/cloudsql/test/createTables.test.js b/appengine/cloudsql/test/createTables.test.js
index 09d4a01ec1..b79ac4bd28 100644
--- a/appengine/cloudsql/test/createTables.test.js
+++ b/appengine/cloudsql/test/createTables.test.js
@@ -56,13 +56,13 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   /* eslint-disable no-console */
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
@@ -87,7 +87,7 @@ describe('gae_flex_mysql_create_tables', () => {
       exampleConfig
     );
 
-    await new Promise(r => setTimeout(r, 10));
+    await new Promise((r) => setTimeout(r, 10));
     assert.ok(sample.mocks.Knex.calledOnce);
     assert.deepStrictEqual(sample.mocks.Knex.firstCall.args, [
       {
@@ -116,7 +116,7 @@ describe('gae_flex_mysql_create_tables', () => {
       prompt: sample.mocks.prompt,
     });
 
-    await new Promise(r => setTimeout(r, 10));
+    await new Promise((r) => setTimeout(r, 10));
     assert.ok(console.error.calledOnce);
     assert.ok(console.error.calledWith(error));
     assert.ok(sample.mocks.Knex.notCalled);
@@ -133,7 +133,7 @@ describe('gae_flex_mysql_create_tables', () => {
       knex: sample.mocks.Knex,
       prompt: sample.mocks.prompt,
     });
-    await new Promise(r => setTimeout(r, 10));
+    await new Promise((r) => setTimeout(r, 10));
     assert.ok(console.error.calledOnce);
     assert.ok(
       console.error.calledWith(`Failed to create 'visits' table:`, error)
diff --git a/appengine/cloudsql/test/server.test.js b/appengine/cloudsql/test/server.test.js
index a1e0205284..b93c7c86ec 100644
--- a/appengine/cloudsql/test/server.test.js
+++ b/appengine/cloudsql/test/server.test.js
@@ -99,7 +99,7 @@ describe('gae_flex_mysql_app', () => {
     await request(sample.app)
       .get('/')
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text, expectedResult);
       });
   });
@@ -113,7 +113,7 @@ describe('gae_flex_mysql_app', () => {
     await request(sample.app)
       .get('/')
       .expect(500)
-      .expect(response => {
+      .expect((response) => {
         assert.ok(response.text.includes(expectedResult));
       });
   });
@@ -127,7 +127,7 @@ describe('gae_flex_mysql_app', () => {
     await request(sample.app)
       .get('/')
       .expect(500)
-      .expect(response => {
+      .expect((response) => {
         assert.ok(response.text.includes(expectedResult));
       });
   });
diff --git a/appengine/cloudsql_postgresql/createTables.js b/appengine/cloudsql_postgresql/createTables.js
index ad7ad11fd4..fc5030e604 100644
--- a/appengine/cloudsql_postgresql/createTables.js
+++ b/appengine/cloudsql_postgresql/createTables.js
@@ -34,7 +34,7 @@ prompt.get(FIELDS, async (err, config) => {
 
   // Create the "visits" table
   try {
-    await knex.schema.createTable('visits', table => {
+    await knex.schema.createTable('visits', (table) => {
       table.increments();
       table.timestamp('timestamp');
       table.string('userIp');
diff --git a/appengine/cloudsql_postgresql/server.js b/appengine/cloudsql_postgresql/server.js
index a79bcb7d3f..ba06e57c4a 100644
--- a/appengine/cloudsql_postgresql/server.js
+++ b/appengine/cloudsql_postgresql/server.js
@@ -70,7 +70,7 @@ const insertVisit = (knex, visit) => {
  * @returns {Promise}
  */
 
-const getVisits = async knex => {
+const getVisits = async (knex) => {
   const results = await knex
     .select('timestamp', 'userIp')
     .from('visits')
@@ -78,7 +78,7 @@ const getVisits = async knex => {
     .limit(10);
 
   return results.map(
-    visit => `Time: ${visit.timestamp}, AddrHash: ${visit.userIp}`
+    (visit) => `Time: ${visit.timestamp}, AddrHash: ${visit.userIp}`
   );
 };
 
diff --git a/appengine/cloudsql_postgresql/test/createTables.test.js b/appengine/cloudsql_postgresql/test/createTables.test.js
index 095cd48679..545e95647a 100644
--- a/appengine/cloudsql_postgresql/test/createTables.test.js
+++ b/appengine/cloudsql_postgresql/test/createTables.test.js
@@ -56,12 +56,12 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
@@ -86,7 +86,7 @@ describe('gae_flex_postgres_create_tables', () => {
       exampleConfig
     );
 
-    await new Promise(r => setTimeout(r, 10));
+    await new Promise((r) => setTimeout(r, 10));
     assert.ok(sample.mocks.Knex.calledOnce);
     assert.deepStrictEqual(sample.mocks.Knex.firstCall.args, [
       {
@@ -115,7 +115,7 @@ describe('gae_flex_postgres_create_tables', () => {
       prompt: sample.mocks.prompt,
     });
 
-    await new Promise(r => setTimeout(r, 10));
+    await new Promise((r) => setTimeout(r, 10));
     assert.ok(console.error.calledOnce);
     assert.ok(console.error.calledWith(error));
     assert.ok(sample.mocks.Knex.notCalled);
@@ -133,7 +133,7 @@ describe('gae_flex_postgres_create_tables', () => {
       prompt: sample.mocks.prompt,
     });
 
-    await new Promise(r => setTimeout(r, 10));
+    await new Promise((r) => setTimeout(r, 10));
     assert.ok(console.error.calledOnce);
     assert.ok(
       console.error.calledWith(`Failed to create 'visits' table:`, error)
diff --git a/appengine/cloudsql_postgresql/test/server.test.js b/appengine/cloudsql_postgresql/test/server.test.js
index b34c8541d9..9b104dab6c 100644
--- a/appengine/cloudsql_postgresql/test/server.test.js
+++ b/appengine/cloudsql_postgresql/test/server.test.js
@@ -97,7 +97,7 @@ describe('gae_flex_postgres_app', () => {
     await request(sample.app)
       .get('/')
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text, expectedResult);
       });
   });
@@ -111,7 +111,7 @@ describe('gae_flex_postgres_app', () => {
     await request(sample.app)
       .get('/')
       .expect(500)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text.includes(expectedResult), true);
       });
   });
@@ -125,7 +125,7 @@ describe('gae_flex_postgres_app', () => {
     await request(sample.app)
       .get('/')
       .expect(500)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text.includes(expectedResult), true);
       });
   });
diff --git a/appengine/datastore/app.js b/appengine/datastore/app.js
index a8ea6bb4ad..6634a182db 100644
--- a/appengine/datastore/app.js
+++ b/appengine/datastore/app.js
@@ -36,7 +36,7 @@ const datastore = new Datastore();
  *
  * @param {object} visit The visit record to insert.
  */
-const insertVisit = visit => {
+const insertVisit = (visit) => {
   return datastore.save({
     key: datastore.key('visit'),
     data: visit,
@@ -71,7 +71,7 @@ app.get('/', async (req, res, next) => {
     await insertVisit(visit);
     const [entities] = await getVisits();
     const visits = entities.map(
-      entity => `Time: ${entity.timestamp}, AddrHash: ${entity.userIp}`
+      (entity) => `Time: ${entity.timestamp}, AddrHash: ${entity.userIp}`
     );
     res
       .status(200)
diff --git a/appengine/endpoints/test/app.test.js b/appengine/endpoints/test/app.test.js
index d88e2d7ead..f8097c3747 100644
--- a/appengine/endpoints/test/app.test.js
+++ b/appengine/endpoints/test/app.test.js
@@ -38,18 +38,18 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.error.restore();
 };
 
 beforeEach(stubConsole);
 afterEach(restoreConsole);
 
-it(`sets up the sample`, done => {
+it(`sets up the sample`, (done) => {
   const sample = getSample();
 
   assert.ok(sample.mocks.express.calledOnce);
@@ -62,7 +62,7 @@ it(`should echo a message`, async () => {
     .post('/echo')
     .send({message: 'foo'})
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(response.body.message, 'foo');
     });
 });
@@ -72,7 +72,7 @@ it(`should try to parse encoded info`, async () => {
   await request(sample.app)
     .get('/auth/info/googlejwt')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.deepStrictEqual(response.body, {id: 'anonymous'});
     });
 });
@@ -86,7 +86,7 @@ it(`should successfully parse encoded info`, async () => {
       Buffer.from(JSON.stringify({id: 'foo'})).toString('base64')
     )
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.deepStrictEqual(response.body, {id: 'foo'});
     });
 });
diff --git a/appengine/hello-world/flexible/app.js b/appengine/hello-world/flexible/app.js
index ef16371e7a..4dcc07d20c 100644
--- a/appengine/hello-world/flexible/app.js
+++ b/appengine/hello-world/flexible/app.js
@@ -20,10 +20,7 @@ const express = require('express');
 const app = express();
 
 app.get('/', (req, res) => {
-  res
-    .status(200)
-    .send('Hello, world!')
-    .end();
+  res.status(200).send('Hello, world!').end();
 });
 
 // Start the server
diff --git a/appengine/hello-world/flexible/test/app.test.js b/appengine/hello-world/flexible/test/app.test.js
index 142fa7ba00..8f5d29d786 100644
--- a/appengine/hello-world/flexible/test/app.test.js
+++ b/appengine/hello-world/flexible/test/app.test.js
@@ -4,16 +4,12 @@ const request = require('supertest');
 
 describe('gae_flex_quickstart', () => {
   describe('GET /', () => {
-    it('should get 200', done => {
-      request(app)
-        .get('/')
-        .expect(200, done);
+    it('should get 200', (done) => {
+      request(app).get('/').expect(200, done);
     });
 
-    it('should get Hello World', done => {
-      request(app)
-        .get('/')
-        .expect('Hello, world!', done);
+    it('should get Hello World', (done) => {
+      request(app).get('/').expect('Hello, world!', done);
     });
   });
 });
diff --git a/appengine/hello-world/standard/app.js b/appengine/hello-world/standard/app.js
index deabd9e6f3..b9b499a45c 100644
--- a/appengine/hello-world/standard/app.js
+++ b/appengine/hello-world/standard/app.js
@@ -20,10 +20,7 @@ const express = require('express');
 const app = express();
 
 app.get('/', (req, res) => {
-  res
-    .status(200)
-    .send('Hello, world!')
-    .end();
+  res.status(200).send('Hello, world!').end();
 });
 
 // Start the server
diff --git a/appengine/hello-world/standard/test/app.test.js b/appengine/hello-world/standard/test/app.test.js
index 6854fc36fa..5d58e14412 100644
--- a/appengine/hello-world/standard/test/app.test.js
+++ b/appengine/hello-world/standard/test/app.test.js
@@ -4,16 +4,12 @@ const request = require('supertest');
 
 describe('gae_node_request_example', () => {
   describe('GET /', () => {
-    it('should get 200', done => {
-      request(app)
-        .get('/')
-        .expect(200, done);
+    it('should get 200', (done) => {
+      request(app).get('/').expect(200, done);
     });
 
-    it('should get Hello World', done => {
-      request(app)
-        .get('/')
-        .expect('Hello, world!', done);
+    it('should get Hello World', (done) => {
+      request(app).get('/').expect('Hello, world!', done);
     });
   });
 });
diff --git a/appengine/metadata/flexible/server.js b/appengine/metadata/flexible/server.js
index a7b56c5356..187e68ee9a 100644
--- a/appengine/metadata/flexible/server.js
+++ b/appengine/metadata/flexible/server.js
@@ -45,10 +45,7 @@ const getExternalIp = async () => {
 app.get('/', async (req, res, next) => {
   try {
     const externalIp = await getExternalIp();
-    res
-      .status(200)
-      .send(`External IP: ${externalIp}`)
-      .end();
+    res.status(200).send(`External IP: ${externalIp}`).end();
   } catch (err) {
     next(err);
   }
diff --git a/appengine/metadata/standard/server.js b/appengine/metadata/standard/server.js
index 2a7ee4616c..09cd4bd5b1 100644
--- a/appengine/metadata/standard/server.js
+++ b/appengine/metadata/standard/server.js
@@ -37,10 +37,7 @@ app.get('/', async (req, res, next) => {
   try {
     const response = await getProjectId();
     const projectId = response.body;
-    res
-      .status(200)
-      .send(`Project ID: ${projectId}`)
-      .end();
+    res.status(200).send(`Project ID: ${projectId}`).end();
   } catch (error) {
     if (error && error.statusCode && error.statusCode !== 200) {
       console.log('Error while talking to metadata server.');
diff --git a/appengine/pubsub/test/app.test.js b/appengine/pubsub/test/app.test.js
index f5accfb133..1dbd56624d 100644
--- a/appengine/pubsub/test/app.test.js
+++ b/appengine/pubsub/test/app.test.js
@@ -72,7 +72,7 @@ describe('gae_flex_pubsub_index', () => {
       .type('form')
       .send({payload: payload})
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert(new RegExp(/Message \d* sent/).test(response.text));
       });
   });
@@ -81,7 +81,7 @@ describe('gae_flex_pubsub_index', () => {
     await requestObj
       .get('/')
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert(
           new RegExp(/Messages received by this instance/).test(response.text)
         );
@@ -103,10 +103,7 @@ describe('gae_flex_pubsub_push', () => {
   });
 
   it('should check for verification token on incoming Pub/Sub messages', async () => {
-    await requestObj
-      .post('/pubsub/push')
-      .field('payload', payload)
-      .expect(400);
+    await requestObj.post('/pubsub/push').field('payload', payload).expect(400);
   });
 });
 
@@ -135,7 +132,7 @@ describe('gae_flex_pubsub_auth_push', () => {
     await requestObj
       .get('/')
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert(response.text.includes(payload));
       });
   });
diff --git a/appengine/redis/server.js b/appengine/redis/server.js
index 698a43d7f9..f6d3a408d8 100644
--- a/appengine/redis/server.js
+++ b/appengine/redis/server.js
@@ -21,10 +21,7 @@ const nconf = require('nconf');
 // read in keys and secrets. You can store these in a variety of ways.
 // I like to use a keys.json file that is in the .gitignore file,
 // but you can also store them in environment variables
-nconf
-  .argv()
-  .env()
-  .file('keys.json');
+nconf.argv().env().file('keys.json');
 
 // [START gae_flex_node_redis]
 // Connect to a redis server provisioned over at
@@ -38,7 +35,7 @@ const client = redis
       return_buffers: true,
     }
   )
-  .on('error', err => console.error('ERR:REDIS:', err));
+  .on('error', (err) => console.error('ERR:REDIS:', err));
 // [END gae_flex_node_redis]]
 
 // Create a simple little server.
@@ -58,7 +55,7 @@ http
         return;
       }
 
-      data.forEach(ip => {
+      data.forEach((ip) => {
         iplist += `${ip}; `;
       });
 
diff --git a/appengine/sendgrid/test/app.test.js b/appengine/sendgrid/test/app.test.js
index afbc3f54ac..71206688da 100644
--- a/appengine/sendgrid/test/app.test.js
+++ b/appengine/sendgrid/test/app.test.js
@@ -11,7 +11,7 @@ describe('gae_flex_sendgrid', () => {
     await request
       .get('/')
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert(response.text.includes('Hello World!'));
       });
   });
@@ -22,7 +22,7 @@ describe('gae_flex_sendgrid', () => {
       .type('form')
       .send({email: 'testuser@google.com'})
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert(response.text.includes('Email sent!'));
       });
   });
diff --git a/appengine/storage/flexible/app.js b/appengine/storage/flexible/app.js
index 34aa709613..d3710b2407 100644
--- a/appengine/storage/flexible/app.js
+++ b/appengine/storage/flexible/app.js
@@ -64,7 +64,7 @@ app.post('/upload', multer.single('file'), (req, res, next) => {
   const blob = bucket.file(req.file.originalname);
   const blobStream = blob.createWriteStream();
 
-  blobStream.on('error', err => {
+  blobStream.on('error', (err) => {
     next(err);
   });
 
diff --git a/appengine/storage/flexible/system-test/app.test.js b/appengine/storage/flexible/system-test/app.test.js
index c2c8c323b4..54cba6fa8e 100644
--- a/appengine/storage/flexible/system-test/app.test.js
+++ b/appengine/storage/flexible/system-test/app.test.js
@@ -53,7 +53,7 @@ it('should load', async () => {
   await requestObj
     .get('/')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(
         new RegExp(/<input type="file" name="file">/).test(response.text),
         true
@@ -66,7 +66,7 @@ it('should upload a file', async () => {
     .post('/upload')
     .attach('file', path.join(__dirname, 'resources/test.txt'))
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(
         response.text,
         `https://storage.googleapis.com/${bucketName}/test.txt`
diff --git a/appengine/storage/standard/app.js b/appengine/storage/standard/app.js
index 113f3f3948..c53c860288 100644
--- a/appengine/storage/standard/app.js
+++ b/appengine/storage/standard/app.js
@@ -66,7 +66,7 @@ app.post('/upload', multer.single('file'), (req, res, next) => {
     resumable: false,
   });
 
-  blobStream.on('error', err => {
+  blobStream.on('error', (err) => {
     next(err);
   });
 
diff --git a/appengine/storage/standard/system-test/app.test.js b/appengine/storage/standard/system-test/app.test.js
index c2c8c323b4..54cba6fa8e 100644
--- a/appengine/storage/standard/system-test/app.test.js
+++ b/appengine/storage/standard/system-test/app.test.js
@@ -53,7 +53,7 @@ it('should load', async () => {
   await requestObj
     .get('/')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(
         new RegExp(/<input type="file" name="file">/).test(response.text),
         true
@@ -66,7 +66,7 @@ it('should upload a file', async () => {
     .post('/upload')
     .attach('file', path.join(__dirname, 'resources/test.txt'))
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(
         response.text,
         `https://storage.googleapis.com/${bucketName}/test.txt`
diff --git a/appengine/twilio/app.js b/appengine/twilio/app.js
index f55a78b335..0fa6a9d553 100644
--- a/appengine/twilio/app.js
+++ b/appengine/twilio/app.js
@@ -44,10 +44,7 @@ app.post('/call/receive', (req, res) => {
 
   twiml.say('Hello from Google App Engine.');
 
-  res
-    .status(200)
-    .contentType('text/xml')
-    .send(twiml.toString());
+  res.status(200).contentType('text/xml').send(twiml.toString());
 });
 // [END gae_flex_twilio_receive_call]
 
@@ -83,10 +80,7 @@ app.post('/sms/receive', bodyParser, (req, res) => {
   const twiml = new twilio.twiml.MessagingResponse();
   twiml.message(`Hello, ${sender}, you said: ${body}`);
 
-  res
-    .status(200)
-    .contentType('text/xml')
-    .send(twiml.toString());
+  res.status(200).contentType('text/xml').send(twiml.toString());
 });
 // [END gae_flex_twilio_receive_sms]
 
diff --git a/appengine/twilio/test/app.test.js b/appengine/twilio/test/app.test.js
index dcb89b5cc2..ac45e6d080 100644
--- a/appengine/twilio/test/app.test.js
+++ b/appengine/twilio/test/app.test.js
@@ -60,7 +60,7 @@ describe('gae_flex_twilio_send_sms', () => {
       .get('/sms/send')
       .query({to: 1234})
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text, 'Message sent.');
       });
   });
diff --git a/appengine/websockets/app.js b/appengine/websockets/app.js
index 6b9875c8c6..58eb0c167b 100644
--- a/appengine/websockets/app.js
+++ b/appengine/websockets/app.js
@@ -25,8 +25,8 @@ app.get('/', (req, res) => {
   res.render('index.pug');
 });
 
-io.on('connection', socket => {
-  socket.on('chat message', msg => {
+io.on('connection', (socket) => {
+  socket.on('chat message', (msg) => {
     io.emit('chat message', msg);
   });
 });
diff --git a/appengine/websockets/test/index.test.js b/appengine/websockets/test/index.test.js
index f1d3c2216b..aa3f64e7e7 100644
--- a/appengine/websockets/test/index.test.js
+++ b/appengine/websockets/test/index.test.js
@@ -40,7 +40,7 @@ describe('appengine_websockets_app', () => {
       document.querySelector('button').click();
     });
 
-    await new Promise(resolve => setTimeout(resolve, 100));
+    await new Promise((resolve) => setTimeout(resolve, 100));
 
     const itemText = await browserPage.evaluate(
       () => document.querySelector('li').textContent
diff --git a/auth/auth.js b/auth/auth.js
index ea9d173e51..43318a5edc 100644
--- a/auth/auth.js
+++ b/auth/auth.js
@@ -36,7 +36,7 @@ const authCloudImplicit = async () => {
     const [buckets] = results;
 
     console.log('Buckets:');
-    buckets.forEach(bucket => {
+    buckets.forEach((bucket) => {
       console.log(bucket.name);
     });
   } catch (err) {
@@ -62,7 +62,7 @@ const authCloudExplicit = async ({projectId, keyFilename}) => {
     const [buckets] = await storage.getBuckets();
 
     console.log('Buckets:');
-    buckets.forEach(bucket => {
+    buckets.forEach((bucket) => {
       console.log(bucket.name);
     });
   } catch (err) {
diff --git a/cloud-sql/mysql/mysql/server.js b/cloud-sql/mysql/mysql/server.js
index f8091b9a4a..a7b9485ff0 100644
--- a/cloud-sql/mysql/mysql/server.js
+++ b/cloud-sql/mysql/mysql/server.js
@@ -130,10 +130,7 @@ app.post('/', async (req, res) => {
   const timestamp = new Date();
 
   if (!team || (team !== 'TABS' && team !== 'SPACES')) {
-    res
-      .status(400)
-      .send('Invalid team specified.')
-      .end();
+    res.status(400).send('Invalid team specified.').end();
   }
 
   // [START cloud_sql_mysql_mysql_connection]
@@ -157,10 +154,7 @@ app.post('/', async (req, res) => {
   }
   // [END cloud_sql_mysql_mysql_connection]
 
-  res
-    .status(200)
-    .send(`Successfully voted for ${team} at ${timestamp}`)
-    .end();
+  res.status(200).send(`Successfully voted for ${team} at ${timestamp}`).end();
 });
 
 const PORT = process.env.PORT || 8080;
diff --git a/cloud-sql/mysql/mysql/test/server.test.js b/cloud-sql/mysql/mysql/test/server.test.js
index 82dd88dec9..23a9b6615f 100644
--- a/cloud-sql/mysql/mysql/test/server.test.js
+++ b/cloud-sql/mysql/mysql/test/server.test.js
@@ -30,9 +30,7 @@ stubMysql.createPool.returns(poolStub);
 const server = require('../server.js');
 
 it('check index page', async () => {
-  const response = await request(server)
-    .get('/')
-    .timeout(1000);
+  const response = await request(server).get('/').timeout(1000);
 
   assert.strictEqual(response.status, 200);
 });
diff --git a/cloud-sql/postgres/knex/createTable.js b/cloud-sql/postgres/knex/createTable.js
index 4406631f23..07aaf96ecf 100644
--- a/cloud-sql/postgres/knex/createTable.js
+++ b/cloud-sql/postgres/knex/createTable.js
@@ -16,14 +16,14 @@
 
 const Knex = require('knex');
 
-const createTable = async config => {
+const createTable = async (config) => {
   // Connect to the database
   config.host = `/cloudsql/${config.connectionName}`;
   const knex = Knex({client: 'pg', connection: config});
 
   // Create the "votes" table
   try {
-    await knex.schema.createTable('votes', table => {
+    await knex.schema.createTable('votes', (table) => {
       table.bigIncrements('vote_id').notNull();
       table.timestamp('time_cast').notNull();
       table.specificType('candidate', 'CHAR(6) NOT NULL');
diff --git a/cloud-sql/postgres/knex/server.js b/cloud-sql/postgres/knex/server.js
index a4aaae2bd6..5b7388c855 100644
--- a/cloud-sql/postgres/knex/server.js
+++ b/cloud-sql/postgres/knex/server.js
@@ -126,7 +126,7 @@ const insertVote = async (knex, vote) => {
  * @param {object} knex The Knex connection object.
  * @returns {Promise}
  */
-const getVotes = async knex => {
+const getVotes = async (knex) => {
   return await knex
     .select('candidate', 'time_cast')
     .from('votes')
@@ -143,13 +143,11 @@ const getVotes = async knex => {
  * @returns {Promise}
  */
 const getVoteCount = async (knex, candidate) => {
-  return await knex('votes')
-    .count('vote_id')
-    .where('candidate', candidate);
+  return await knex('votes').count('vote_id').where('candidate', candidate);
 };
 
 app.get('/', (req, res) => {
-  (async function() {
+  (async function () {
     // Query the total count of "TABS" from the database.
     const tabsResult = await getVoteCount(knex, 'TABS');
     const tabsTotalVotes = parseInt(tabsResult[0].count);
@@ -193,10 +191,7 @@ app.post('/', async (req, res) => {
   const timestamp = new Date();
 
   if (!team || (team !== 'TABS' && team !== 'SPACES')) {
-    res
-      .status(400)
-      .send('Invalid team specified.')
-      .end();
+    res.status(400).send('Invalid team specified.').end();
     return;
   }
 
@@ -217,10 +212,7 @@ app.post('/', async (req, res) => {
       .end();
     return;
   }
-  res
-    .status(200)
-    .send(`Successfully voted for ${team} at ${timestamp}`)
-    .end();
+  res.status(200).send(`Successfully voted for ${team} at ${timestamp}`).end();
 });
 
 const PORT = process.env.PORT || 8080;
diff --git a/cloud-sql/postgres/knex/test/createTable.test.js b/cloud-sql/postgres/knex/test/createTable.test.js
index aa2e71ed84..a02aa67f31 100644
--- a/cloud-sql/postgres/knex/test/createTable.test.js
+++ b/cloud-sql/postgres/knex/test/createTable.test.js
@@ -41,7 +41,7 @@ before(async () => {
   }
 });
 
-it('should create a table', done => {
+it('should create a table', (done) => {
   exec(
     `node createTable.js ${DB_USER} ${DB_PASS} ${DB_NAME} ${CONNECTION_NAME}`,
     {cwd},
@@ -52,7 +52,7 @@ it('should create a table', done => {
   );
 });
 
-it('should handle existing tables', done => {
+it('should handle existing tables', (done) => {
   exec(
     `node createTable.js ${DB_USER} ${DB_PASS} ${DB_NAME} ${CONNECTION_NAME}`,
     {cwd},
diff --git a/cloud-sql/postgres/knex/test/server.test.js b/cloud-sql/postgres/knex/test/server.test.js
index 0b3b726ae5..8b16e62977 100644
--- a/cloud-sql/postgres/knex/test/server.test.js
+++ b/cloud-sql/postgres/knex/test/server.test.js
@@ -30,7 +30,7 @@ it('should display the default page', async () => {
   await request(server)
     .get('/')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.ok(response.text.includes('Tabs VS Spaces'));
     });
 });
@@ -41,7 +41,7 @@ it('should handle insert error', async () => {
   await request(server)
     .post('/')
     .expect(400)
-    .expect(response => {
+    .expect((response) => {
       assert.ok(response.text.includes(expectedResult));
     });
 });
diff --git a/cloud-tasks/app/createTask.js b/cloud-tasks/app/createTask.js
index 49186094c2..cbe7ce51ff 100644
--- a/cloud-tasks/app/createTask.js
+++ b/cloud-tasks/app/createTask.js
@@ -17,7 +17,7 @@
 // [START cloud_tasks_app_create_task]
 const MAX_SCHEDULE_LIMIT = 30 * 60 * 60 * 24; // Represents 30 days in seconds.
 
-const createHttpTaskWithToken = async function(
+const createHttpTaskWithToken = async function (
   project = 'my-project-id', // Your GCP Project id
   queue = 'my-queue', // Name of your Queue
   location = 'us-central1', // The GCP region of your queue
diff --git a/cloud-tasks/function/index.js b/cloud-tasks/function/index.js
index 1102afff3e..159c98818b 100644
--- a/cloud-tasks/function/index.js
+++ b/cloud-tasks/function/index.js
@@ -76,7 +76,7 @@ exports.sendEmail = async (req, res) => {
 // [END cloud_tasks_func]
 
 // Function creates an HTML postcard with message.
-const postcardHTML = function(to_name, from_name) {
+const postcardHTML = function (to_name, from_name) {
   return `<html>
   <head>
     <style>
diff --git a/cloud-tasks/function/test/index.test.js b/cloud-tasks/function/test/index.test.js
index 0aec12ed5f..e2b32f6be0 100644
--- a/cloud-tasks/function/test/index.test.js
+++ b/cloud-tasks/function/test/index.test.js
@@ -20,10 +20,10 @@ const assert = require('assert');
 
 const key = process.env.SENDGRID_API_KEY;
 
-const getSample = function() {
+const getSample = function () {
   const requestPromise = sinon
     .stub()
-    .returns(new Promise(resolve => resolve('test')));
+    .returns(new Promise((resolve) => resolve('test')));
 
   return {
     program: proxyquire('../', {
@@ -35,14 +35,14 @@ const getSample = function() {
   };
 };
 
-const getMocks = function() {
+const getMocks = function () {
   const req = {
     body: {},
   };
 
   const res = {
     send: sinon.stub().returnsThis(),
-    status: function(statusCode) {
+    status: function (statusCode) {
       this.statusCode = statusCode;
       return this;
     },
diff --git a/containerengine/hello-world/server.js b/containerengine/hello-world/server.js
index 24d660fd4e..0681877709 100644
--- a/containerengine/hello-world/server.js
+++ b/containerengine/hello-world/server.js
@@ -16,7 +16,7 @@
 
 // [START all]
 const http = require('http');
-const handleRequest = function(req, res) {
+const handleRequest = function (req, res) {
   res.writeHead(200);
   res.end('Hello Kubernetes!');
 };
diff --git a/datacatalog/cloud-client/system-test/createEntryGroup.test.js b/datacatalog/cloud-client/system-test/createEntryGroup.test.js
index 86aba94164..bb77c7620c 100644
--- a/datacatalog/cloud-client/system-test/createEntryGroup.test.js
+++ b/datacatalog/cloud-client/system-test/createEntryGroup.test.js
@@ -40,7 +40,7 @@ before(() => {
 });
 
 describe('createEntryGroup', () => {
-  it('should create a entry group', done => {
+  it('should create a entry group', (done) => {
     const expectedName = `projects/${projectId}/locations/${location}/entryGroups/${entryGroupId}`;
     exec(
       `node createEntryGroup.js ${projectId} ${entryGroupId}`,
diff --git a/datacatalog/cloud-client/system-test/createFilesetEntry.test.js b/datacatalog/cloud-client/system-test/createFilesetEntry.test.js
index b5721e90ba..20f7a3ee79 100644
--- a/datacatalog/cloud-client/system-test/createFilesetEntry.test.js
+++ b/datacatalog/cloud-client/system-test/createFilesetEntry.test.js
@@ -41,12 +41,12 @@ before(() => {
 });
 
 describe('createFilesetEntry', () => {
-  before(done => {
+  before((done) => {
     // Must create entryGroup before creating entry
     exec(`node createEntryGroup.js ${projectId} ${entryGroupId}`, {cwd}, done);
   });
 
-  it('should create a fileset entry', done => {
+  it('should create a fileset entry', (done) => {
     const expectedLinkedResource = `//datacatalog.googleapis.com/projects/${projectId}/locations/${location}/entryGroups/${entryGroupId}/entries/${entryId}`;
     exec(
       `node createFilesetEntry.js ${projectId} ${entryGroupId} ${entryId}`,
diff --git a/datacatalog/cloud-client/system-test/lookupEntry.test.js b/datacatalog/cloud-client/system-test/lookupEntry.test.js
index 42f7c7fd0c..ffb9b3da4d 100644
--- a/datacatalog/cloud-client/system-test/lookupEntry.test.js
+++ b/datacatalog/cloud-client/system-test/lookupEntry.test.js
@@ -31,7 +31,7 @@ before(() => {
 });
 
 describe('lookupEntry lookup', () => {
-  it('should lookup a dataset entry', done => {
+  it('should lookup a dataset entry', (done) => {
     const projectId = 'bigquery-public-data';
     const datasetId = 'new_york_taxi_trips';
     const expectedLinkedResource = `//bigquery.googleapis.com/projects/${projectId}/datasets/${datasetId}`;
diff --git a/datacatalog/quickstart/system-test/createFilesetEntry.test.js b/datacatalog/quickstart/system-test/createFilesetEntry.test.js
index 65b3e1d3ee..c3a78014db 100644
--- a/datacatalog/quickstart/system-test/createFilesetEntry.test.js
+++ b/datacatalog/quickstart/system-test/createFilesetEntry.test.js
@@ -41,7 +41,7 @@ before(() => {
 });
 
 describe('createFilesetEntry', () => {
-  it('should create a fileset entry', done => {
+  it('should create a fileset entry', (done) => {
     const expectedLinkedResource = `//datacatalog.googleapis.com/projects/${projectId}/locations/${location}/entryGroups/${entryGroupId}/entries/${entryId}`;
     exec(
       `node createFilesetEntry.js ${projectId} ${entryGroupId} ${entryId}`,
diff --git a/datacatalog/quickstart/system-test/deleteFilesetEntry.test.js b/datacatalog/quickstart/system-test/deleteFilesetEntry.test.js
index b92149f944..b4f31248bc 100644
--- a/datacatalog/quickstart/system-test/deleteFilesetEntry.test.js
+++ b/datacatalog/quickstart/system-test/deleteFilesetEntry.test.js
@@ -41,7 +41,7 @@ before(() => {
 });
 
 describe('deleteFilesetEntry', () => {
-  before(done => {
+  before((done) => {
     // Must create an entry to be deleted.
     exec(
       `node createFilesetEntry.js ${projectId} ${entryGroupId} ${entryId}`,
@@ -50,7 +50,7 @@ describe('deleteFilesetEntry', () => {
     );
   });
 
-  it('should delete a fileset entry', done => {
+  it('should delete a fileset entry', (done) => {
     exec(
       `node deleteFilesetEntry.js ${projectId} ${entryGroupId} ${entryId}`,
       {cwd},
diff --git a/datastore/functions/index.js b/datastore/functions/index.js
index 35f30da559..91f45a70c5 100644
--- a/datastore/functions/index.js
+++ b/datastore/functions/index.js
@@ -19,7 +19,7 @@ const {Datastore} = require('@google-cloud/datastore');
 // Instantiates a client
 const datastore = new Datastore();
 
-const makeErrorObj = prop => {
+const makeErrorObj = (prop) => {
   return new Error(
     `${prop} not provided. Make sure you have a "${prop.toLowerCase()}" property in your request`
   );
@@ -33,7 +33,7 @@ const makeErrorObj = prop => {
  * @param {string} requestData.kind Datastore kind.
  * @returns {object} Datastore key object.
  */
-const getKeyFromRequestData = requestData => {
+const getKeyFromRequestData = (requestData) => {
   if (!requestData.key) {
     return Promise.reject(makeErrorObj('Key'));
   }
diff --git a/datastore/functions/test/index.test.js b/datastore/functions/test/index.test.js
index 5d773ededb..8d3b4cbd55 100644
--- a/datastore/functions/test/index.test.js
+++ b/datastore/functions/test/index.test.js
@@ -34,10 +34,10 @@ const VALUE = {
   description: 'Buy milk',
 };
 
-const errorMsg = msg =>
+const errorMsg = (msg) =>
   `${msg} not provided. Make sure you have a "${msg.toLowerCase()}" property in your request`;
 
-const handleLinuxFailures = async proc => {
+const handleLinuxFailures = async (proc) => {
   try {
     return await proc;
   } catch (err) {
@@ -50,10 +50,10 @@ const handleLinuxFailures = async proc => {
 };
 
 // Wait for the HTTP server to start listening
-const waitForReady = async baseUrl => {
+const waitForReady = async (baseUrl) => {
   let ready = false;
   while (!ready) {
-    await new Promise(r => setTimeout(r, 500));
+    await new Promise((r) => setTimeout(r, 500));
     ready = await isReachable(baseUrl);
   }
 };
diff --git a/endpoints/getting-started-grpc/client.js b/endpoints/getting-started-grpc/client.js
index d3f3e7df85..0240e140cf 100644
--- a/endpoints/getting-started-grpc/client.js
+++ b/endpoints/getting-started-grpc/client.js
@@ -83,7 +83,7 @@ const {argv} = require('yargs')
     default: 'world',
     global: true,
   })
-  .check(argv => {
+  .check((argv) => {
     const valid = !!(argv.jwtAuthToken || argv.apiKey);
     if (!valid) {
       console.error('One of API_KEY or JWT_AUTH_TOKEN must be set.');
diff --git a/endpoints/getting-started-grpc/server.js b/endpoints/getting-started-grpc/server.js
index 45d13b831d..0ccf64d202 100644
--- a/endpoints/getting-started-grpc/server.js
+++ b/endpoints/getting-started-grpc/server.js
@@ -26,7 +26,7 @@ const sayHello = (call, callback) => {
 };
 
 // Start an RPC server to handle Greeter service requests
-const startServer = PORT => {
+const startServer = (PORT) => {
   const server = new grpc.Server();
   server.addProtoService(helloProto.Greeter.service, {sayHello: sayHello});
   server.bind(`0.0.0.0:${PORT}`, grpc.ServerCredentials.createInsecure());
diff --git a/endpoints/getting-started/app.js b/endpoints/getting-started/app.js
index c75072a7d0..5dc3e775fe 100644
--- a/endpoints/getting-started/app.js
+++ b/endpoints/getting-started/app.js
@@ -26,10 +26,7 @@ app.use(bodyParser.json());
 // [END setup]
 
 app.post('/echo', (req, res) => {
-  res
-    .status(200)
-    .json({message: req.body.message})
-    .end();
+  res.status(200).json({message: req.body.message}).end();
 });
 
 const authInfoHandler = (req, res) => {
@@ -38,10 +35,7 @@ const authInfoHandler = (req, res) => {
   if (encodedInfo) {
     authUser = JSON.parse(Buffer.from(encodedInfo, 'base64'));
   }
-  res
-    .status(200)
-    .json(authUser)
-    .end();
+  res.status(200).json(authUser).end();
 };
 
 app.get('/auth/info/googlejwt', authInfoHandler);
diff --git a/endpoints/getting-started/test/app.test.js b/endpoints/getting-started/test/app.test.js
index e6bb81567e..cf39ca80d2 100644
--- a/endpoints/getting-started/test/app.test.js
+++ b/endpoints/getting-started/test/app.test.js
@@ -39,12 +39,12 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
 };
 
 //Restore console
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.error.restore();
 };
 
@@ -56,7 +56,7 @@ it('should echo a message', async () => {
     .post('/echo')
     .send({message: 'foo'})
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.strictEqual(response.body.message, 'foo');
     });
 });
@@ -65,7 +65,7 @@ it('should try to parse encoded info', async () => {
   await request(getSample().app)
     .get('/auth/info/googlejwt')
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.deepStrictEqual(response.body, {id: 'anonymous'});
     });
 });
@@ -78,7 +78,7 @@ it('should successfully parse encoded info', async () => {
       Buffer.from(JSON.stringify({id: 'foo'})).toString('base64')
     )
     .expect(200)
-    .expect(response => {
+    .expect((response) => {
       assert.deepStrictEqual(response.body, {id: 'foo'});
     });
 });
diff --git a/functions/background/index.js b/functions/background/index.js
index cd00fc2332..e75d861a45 100644
--- a/functions/background/index.js
+++ b/functions/background/index.js
@@ -25,7 +25,7 @@ const {request} = require('gaxios');
  * @param {object} data.endpoint The URL to send the request to.
  * @returns {Promise}
  */
-exports.helloPromise = data => {
+exports.helloPromise = (data) => {
   return request({
     url: data.endpoint,
   });
diff --git a/functions/billing/index.js b/functions/billing/index.js
index 4012818dc2..a339b29c2f 100644
--- a/functions/billing/index.js
+++ b/functions/billing/index.js
@@ -93,7 +93,7 @@ const _setAuthCredential = async () => {
  * @param {string} projectName Name of project to check if billing is enabled
  * @return {bool} Whether project has billing enabled or not
  */
-const _isBillingEnabled = async projectName => {
+const _isBillingEnabled = async (projectName) => {
   const res = await billing.getBillingInfo({name: projectName});
   return res.data.billingEnabled;
 };
@@ -103,7 +103,7 @@ const _isBillingEnabled = async projectName => {
  * @param {string} projectName Name of project disable billing on
  * @return {string} Text containing response from disabling billing
  */
-const _disableBillingForProject = async projectName => {
+const _disableBillingForProject = async (projectName) => {
   const res = await billing.updateBillingInfo({
     name: projectName,
     resource: {billingAccountName: ''}, // Disable billing
@@ -168,8 +168,8 @@ const _listRunningInstances = async (projectId, zone) => {
   });
 
   const instances = res.data.items || [];
-  const ranInstances = instances.filter(item => item.status === 'RUNNING');
-  return ranInstances.map(item => item.name);
+  const ranInstances = instances.filter((item) => item.status === 'RUNNING');
+  return ranInstances.map((item) => item.name);
 };
 
 /**
@@ -178,14 +178,14 @@ const _listRunningInstances = async (projectId, zone) => {
  */
 const _stopInstances = async (projectId, zone, instanceNames) => {
   await Promise.all(
-    instanceNames.map(instanceName => {
+    instanceNames.map((instanceName) => {
       return compute.instances
         .stop({
           project: projectId,
           zone: zone,
           instance: instanceName,
         })
-        .then(res => {
+        .then((res) => {
           console.log(`Instance stopped successfully: ${instanceName}`);
           return res.data;
         });
@@ -217,8 +217,10 @@ const _listStoppedInstances = async (projectId, zone) => {
   });
 
   const instances = res.data.items || [];
-  const stoppedInstances = instances.filter(item => item.status !== 'RUNNING');
-  return stoppedInstances.map(item => item.name);
+  const stoppedInstances = instances.filter(
+    (item) => item.status !== 'RUNNING'
+  );
+  return stoppedInstances.map((item) => item.name);
 };
 
 /**
@@ -230,7 +232,7 @@ const _startInstances = async (projectId, zone, instanceNames) => {
     return 'No stopped instances were found.';
   }
   await Promise.all(
-    instanceNames.map(instanceName => {
+    instanceNames.map((instanceName) => {
       return compute.instances.start({
         project: projectId,
         zone: zone,
diff --git a/functions/billing/test/index.test.js b/functions/billing/test/index.test.js
index d2d65c557d..5a8ba0fa32 100644
--- a/functions/billing/test/index.test.js
+++ b/functions/billing/test/index.test.js
@@ -39,7 +39,7 @@ after(async () => {
   await require('../').startBilling(pubsubMessage);
 });
 
-const handleLinuxFailures = async proc => {
+const handleLinuxFailures = async (proc) => {
   try {
     return await proc;
   } catch (err) {
diff --git a/functions/composer-storage-trigger/index.js b/functions/composer-storage-trigger/index.js
index ade0ffccc2..52c9ee0916 100644
--- a/functions/composer-storage-trigger/index.js
+++ b/functions/composer-storage-trigger/index.js
@@ -31,7 +31,7 @@ const FormData = require('form-data');
  * @param {!Object} data The Cloud Functions event data.
  * @returns {Promise}
  */
-exports.triggerDag = async data => {
+exports.triggerDag = async (data) => {
   // Fill in your Composer environment information here.
 
   // The project that holds your function
diff --git a/functions/composer-storage-trigger/test/index.test.js b/functions/composer-storage-trigger/test/index.test.js
index d75fe0b153..9533fa040f 100644
--- a/functions/composer-storage-trigger/test/index.test.js
+++ b/functions/composer-storage-trigger/test/index.test.js
@@ -18,7 +18,7 @@ const proxyquire = require('proxyquire').noCallThru();
 const sinon = require('sinon');
 const assert = require('assert');
 
-const getSample = FetchStub => {
+const getSample = (FetchStub) => {
   return {
     program: proxyquire('../', {
       'node-fetch': FetchStub,
diff --git a/functions/firebase/index.js b/functions/firebase/index.js
index 82aacd8dc7..f4f963f34f 100644
--- a/functions/firebase/index.js
+++ b/functions/firebase/index.js
@@ -18,13 +18,13 @@
  *
  * @param {!Object} event The Cloud Functions event.
  */
-exports.helloRTDB = event => {
+exports.helloRTDB = (event) => {
   const triggerResource = event.resource;
 
   const pathParams = event.params;
   if (pathParams) {
     console.log(`Path parameters:`);
-    Object.keys(pathParams).forEach(key => {
+    Object.keys(pathParams).forEach((key) => {
       console.log(`  ${key}: ${pathParams[key]}`);
     });
   }
@@ -42,7 +42,7 @@ exports.helloRTDB = event => {
  *
  * @param {!Object} event The Cloud Functions event.
  */
-exports.helloFirestore = event => {
+exports.helloFirestore = (event) => {
   const triggerResource = event.resource;
 
   console.log(`Function triggered by event on: ${triggerResource}`);
@@ -66,7 +66,7 @@ exports.helloFirestore = event => {
  *
  * @param {!Object} event The Cloud Functions event.
  */
-exports.helloAuth = event => {
+exports.helloAuth = (event) => {
   try {
     const {data} = event;
     console.log(`Function triggered by change to user: ${data.uid}`);
@@ -89,7 +89,7 @@ const firestore = new Firestore({
 });
 
 // Converts strings added to /messages/{pushId}/original to uppercase
-exports.makeUpperCase = event => {
+exports.makeUpperCase = (event) => {
   const {resource} = event;
   const affectedDoc = firestore.doc(resource.split('/documents/')[1]);
 
@@ -109,7 +109,7 @@ exports.makeUpperCase = event => {
  *
  * @param {!Object} event The Cloud Functions event.
  */
-exports.helloAnalytics = event => {
+exports.helloAnalytics = (event) => {
   const {resource} = event;
   console.log(`Function triggered by the following event: ${resource}`);
 
@@ -129,7 +129,7 @@ exports.helloAnalytics = event => {
  *
  * @param {object} data The Cloud Functions event data.
  */
-exports.helloRemoteConfig = event => {
+exports.helloRemoteConfig = (event) => {
   const {data} = event;
 
   console.log(`Update type: ${data.updateType}`);
diff --git a/functions/firebase/test/index.test.js b/functions/firebase/test/index.test.js
index 73803d56c8..96ec407f9b 100644
--- a/functions/firebase/test/index.test.js
+++ b/functions/firebase/test/index.test.js
@@ -34,12 +34,12 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/functions/helloworld/test/sample.system.http.test.js b/functions/helloworld/test/sample.system.http.test.js
index de4a97d6f5..81be6c9baf 100644
--- a/functions/helloworld/test/sample.system.http.test.js
+++ b/functions/helloworld/test/sample.system.http.test.js
@@ -23,7 +23,7 @@ describe('system tests', () => {
       .post('/helloHttp')
       .send({name: 'John'})
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text, 'Hello John!');
       });
   });
@@ -33,7 +33,7 @@ describe('system tests', () => {
     await supertest
       .get('/helloHttp')
       .expect(200)
-      .expect(response => {
+      .expect((response) => {
         assert.strictEqual(response.text, 'Hello World!');
       });
   });
diff --git a/functions/helloworld/test/sample.system.pubsub.test.js b/functions/helloworld/test/sample.system.pubsub.test.js
index 8fa68504ad..418eff06ee 100644
--- a/functions/helloworld/test/sample.system.pubsub.test.js
+++ b/functions/helloworld/test/sample.system.pubsub.test.js
@@ -29,16 +29,14 @@ describe('system tests', () => {
     const name = uuid.v4();
 
     // Subtract time to work-around local-GCF clock difference
-    const startTime = moment()
-      .subtract(4, 'minutes')
-      .toISOString();
+    const startTime = moment().subtract(4, 'minutes').toISOString();
 
     // Publish to pub/sub topic
     const topic = pubsub.topic(topicName);
     await topic.publish(Buffer.from(name));
 
     // Wait for logs to become consistent
-    await promiseRetry(retry => {
+    await promiseRetry((retry) => {
       const logs = childProcess
         .execSync(`${baseCmd} logs read helloPubSub --start-time ${startTime}`)
         .toString();
@@ -54,16 +52,14 @@ describe('system tests', () => {
 
   it('helloPubSub: should print hello world', async () => {
     // Subtract time to work-around local-GCF clock difference
-    const startTime = moment()
-      .subtract(4, 'minutes')
-      .toISOString();
+    const startTime = moment().subtract(4, 'minutes').toISOString();
 
     // Publish to pub/sub topic
     const topic = pubsub.topic(topicName);
     await topic.publish(Buffer.from(''), {a: 'b'});
 
     // Wait for logs to become consistent
-    await promiseRetry(retry => {
+    await promiseRetry((retry) => {
       const logs = childProcess
         .execSync(`${baseCmd} logs read helloPubSub --start-time ${startTime}`)
         .toString();
diff --git a/functions/helloworld/test/sample.system.storage.test.js b/functions/helloworld/test/sample.system.storage.test.js
index 13fea47f14..6a0535dcc1 100644
--- a/functions/helloworld/test/sample.system.storage.test.js
+++ b/functions/helloworld/test/sample.system.storage.test.js
@@ -33,9 +33,7 @@ const baseCmd = 'gcloud functions';
 describe('system tests', () => {
   it('helloGCS: should print uploaded message', async () => {
     // Subtract time to work-around local-GCF clock difference
-    const startTime = moment()
-      .subtract(2, 'minutes')
-      .toISOString();
+    const startTime = moment().subtract(2, 'minutes').toISOString();
 
     // Upload file
     const filepath = path.join(__dirname, localFileName);
@@ -44,7 +42,7 @@ describe('system tests', () => {
     });
 
     // Wait for logs to become consistent
-    await promiseRetry(retry => {
+    await promiseRetry((retry) => {
       const logs = childProcess
         .execSync(`${baseCmd} logs read helloGCS --start-time ${startTime}`)
         .toString();
@@ -60,16 +58,14 @@ describe('system tests', () => {
 
   it('helloGCS: should print metadata updated message', async () => {
     // Subtract time to work-around local-GCF clock difference
-    const startTime = moment()
-      .subtract(2, 'minutes')
-      .toISOString();
+    const startTime = moment().subtract(2, 'minutes').toISOString();
 
     // Update file metadata
     const file = bucket.file(gcsFileName);
     await file.setMetadata(gcsFileName, {foo: 'bar'});
 
     // Wait for logs to become consistent
-    await promiseRetry(retry => {
+    await promiseRetry((retry) => {
       const logs = childProcess
         .execSync(`${baseCmd} logs read helloGCS --start-time ${startTime}`)
         .toString();
@@ -84,15 +80,13 @@ describe('system tests', () => {
 
   it('helloGCS: should print deleted message', async () => {
     // Subtract time to work-around local-GCF clock difference
-    const startTime = moment()
-      .subtract(2, 'minutes')
-      .toISOString();
+    const startTime = moment().subtract(2, 'minutes').toISOString();
 
     // Delete file
     bucket.deleteFiles();
 
     // Wait for logs to become consistent
-    await promiseRetry(retry => {
+    await promiseRetry((retry) => {
       const logs = childProcess
         .execSync(`${baseCmd} logs read helloGCS --start-time ${startTime}`)
         .toString();
diff --git a/functions/helloworld/test/sample.unit.pubsub.test.js b/functions/helloworld/test/sample.unit.pubsub.test.js
index 3bb1e272bc..647579b884 100644
--- a/functions/helloworld/test/sample.unit.pubsub.test.js
+++ b/functions/helloworld/test/sample.unit.pubsub.test.js
@@ -20,12 +20,12 @@ describe('functions_helloworld_pubsub', () => {
 
   const {helloPubSub} = require('..');
 
-  const stubConsole = function() {
+  const stubConsole = function () {
     sinon.stub(console, `error`);
     sinon.stub(console, `log`);
   };
 
-  const restoreConsole = function() {
+  const restoreConsole = function () {
     console.log.restore();
     console.error.restore();
   };
diff --git a/functions/helloworld/test/sample.unit.storage.test.js b/functions/helloworld/test/sample.unit.storage.test.js
index 9b1fb3ea0a..25174a9446 100644
--- a/functions/helloworld/test/sample.unit.storage.test.js
+++ b/functions/helloworld/test/sample.unit.storage.test.js
@@ -20,12 +20,12 @@ describe('functions_helloworld_storage', () => {
 
   const {helloGCS} = require('..');
 
-  const stubConsole = function() {
+  const stubConsole = function () {
     sinon.stub(console, `error`);
     sinon.stub(console, `log`);
   };
 
-  const restoreConsole = function() {
+  const restoreConsole = function () {
     console.log.restore();
     console.error.restore();
   };
diff --git a/functions/http/test/index.test.js b/functions/http/test/index.test.js
index f7187f50ef..fb332b295a 100644
--- a/functions/http/test/index.test.js
+++ b/functions/http/test/index.test.js
@@ -22,7 +22,7 @@ const uuid = require('uuid');
 const getSample = () => {
   const requestPromise = sinon
     .stub()
-    .returns(new Promise(resolve => resolve('test')));
+    .returns(new Promise((resolve) => resolve('test')));
 
   return {
     sample: proxyquire('../', {
@@ -37,7 +37,7 @@ const getSample = () => {
 const getMocks = () => {
   const req = {
     headers: {},
-    get: function(header) {
+    get: function (header) {
       return this.headers[header];
     },
   };
@@ -65,11 +65,11 @@ const getMocks = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.error.restore();
 };
 
@@ -258,7 +258,7 @@ describe('functions_http_signed_url', () => {
 
     // Instead of modifying the sample to return a promise,
     // use a delay here and keep the sample idiomatic
-    await new Promise(resolve => setTimeout(resolve, 300));
+    await new Promise((resolve) => setTimeout(resolve, 300));
 
     assert.strictEqual(mocks.res.status.called, false);
     assert.strictEqual(mocks.res.send.calledOnce, true);
diff --git a/functions/imagemagick/index.js b/functions/imagemagick/index.js
index 93b365b4a1..db03778be4 100644
--- a/functions/imagemagick/index.js
+++ b/functions/imagemagick/index.js
@@ -30,7 +30,7 @@ const {BLURRED_BUCKET_NAME} = process.env;
 
 // [START functions_imagemagick_analyze]
 // Blurs uploaded images that are flagged as Adult or Violence.
-exports.blurOffensiveImages = async event => {
+exports.blurOffensiveImages = async (event) => {
   // This event represents the triggering Cloud Storage object.
   const object = event;
 
diff --git a/functions/imagemagick/test/index.test.js b/functions/imagemagick/test/index.test.js
index 1f66ae9f2e..f2b654c4a6 100644
--- a/functions/imagemagick/test/index.test.js
+++ b/functions/imagemagick/test/index.test.js
@@ -61,14 +61,14 @@ describe('functions/imagemagick tests', () => {
   });
 
   before(() => {
-    startFF = port => {
+    startFF = (port) => {
       return execPromise(
         `functions-framework --target=blurOffensiveImages --signature-type=event --port=${port}`,
         {timeout: 15000, shell: true, cwd}
       );
     };
 
-    stopFF = async ffProc => {
+    stopFF = async (ffProc) => {
       try {
         return await ffProc;
       } catch (err) {
@@ -83,11 +83,11 @@ describe('functions/imagemagick tests', () => {
     };
   });
 
-  const stubConsole = function() {
+  const stubConsole = function () {
     sinon.stub(console, `error`);
   };
 
-  const restoreConsole = function() {
+  const restoreConsole = function () {
     console.error.restore();
   };
 
diff --git a/functions/log/index.js b/functions/log/index.js
index ab9644906a..026e5b7013 100644
--- a/functions/log/index.js
+++ b/functions/log/index.js
@@ -43,7 +43,7 @@ const getLogEntries = async () => {
   const [entries] = await logging.getEntries(options);
 
   console.log('Entries:');
-  entries.forEach(entry => console.log(entry));
+  entries.forEach((entry) => console.log(entry));
   return entries;
 };
 // [END functions_log_retrieve]
@@ -55,7 +55,7 @@ const getLogEntries = async () => {
 // https://github.com/googleapis/google-cloud-node/blob/master/docs/authentication.md
 const Monitoring = require('@google-cloud/monitoring');
 
-const getMetrics = callback => {
+const getMetrics = (callback) => {
   // Instantiates a client
   const monitoring = Monitoring.v3().metricServiceApi();
 
@@ -86,16 +86,16 @@ const getMetrics = callback => {
   // Iterate over all elements.
   monitoring
     .listTimeSeries(options)
-    .on('error', err => {
+    .on('error', (err) => {
       error = err;
     })
-    .on('data', element => console.log(element))
+    .on('data', (element) => console.log(element))
     .on('end', () => callback(error));
   // [END functions_log_get_metrics]
 };
 
 // [START functions_log_stackdriver]
-exports.processLogEntry = data => {
+exports.processLogEntry = (data) => {
   const dataBuffer = Buffer.from(data.data, 'base64');
 
   const logEntry = JSON.parse(dataBuffer.toString('ascii')).protoPayload;
diff --git a/functions/log/test/index.test.js b/functions/log/test/index.test.js
index 393d2a18d3..24d93cfd96 100644
--- a/functions/log/test/index.test.js
+++ b/functions/log/test/index.test.js
@@ -50,12 +50,12 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/functions/memorystore/redis/index.js b/functions/memorystore/redis/index.js
index 3c8d8cc6e4..654224d8dc 100644
--- a/functions/memorystore/redis/index.js
+++ b/functions/memorystore/redis/index.js
@@ -23,7 +23,7 @@ const REDISHOST = process.env.REDISHOST || 'localhost';
 const REDISPORT = process.env.REDISPORT || 6379;
 
 const redisClient = redis.createClient(REDISPORT, REDISHOST);
-redisClient.on('error', err => console.error('ERR:REDIS:', err));
+redisClient.on('error', (err) => console.error('ERR:REDIS:', err));
 
 const incrAsync = promisify(redisClient.incr).bind(redisClient);
 
diff --git a/functions/node8/index.js b/functions/node8/index.js
index 01e79a0d9f..1f64459173 100644
--- a/functions/node8/index.js
+++ b/functions/node8/index.js
@@ -236,7 +236,7 @@ exports.helloAnalytics = (data, context) => {
  * @param {object} data The Cloud Functions event data.
  * @returns {Promise}
  */
-exports.helloPromise = data => {
+exports.helloPromise = (data) => {
   return fetch(data.endpoint);
 };
 // [END functions_background_promise_node8]
@@ -269,7 +269,7 @@ exports.makeUpperCase = (data, context) => {
  *
  * @param {object} data The Cloud Functions event data.
  */
-exports.helloRemoteConfig = data => {
+exports.helloRemoteConfig = (data) => {
   console.log(`Update type: ${data.updateType}`);
   console.log(`Origin: ${data.updateOrigin}`);
   console.log(`Version: ${data.versionNumber}`);
@@ -282,7 +282,7 @@ exports.helloRemoteConfig = data => {
  *
  * @param {object} data The event payload.
  */
-exports.helloAsync = async data => {
+exports.helloAsync = async (data) => {
   const result = await fetch('https://www.example.com');
   return result;
 };
diff --git a/functions/node8/test/index.test.js b/functions/node8/test/index.test.js
index 71b12a447b..3ebd92ab6d 100644
--- a/functions/node8/test/index.test.js
+++ b/functions/node8/test/index.test.js
@@ -39,12 +39,12 @@ const getSample = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/functions/ocr/app/index.js b/functions/ocr/app/index.js
index 5e35c82447..bbbd7f5caf 100644
--- a/functions/ocr/app/index.js
+++ b/functions/ocr/app/index.js
@@ -82,7 +82,7 @@ const detectText = async (bucketName, filename) => {
   // Submit a message to the bus for each language we're going to translate to
   const topicName = config.get('TRANSLATE_TOPIC');
 
-  const tasks = config.get('TO_LANG').map(lang => {
+  const tasks = config.get('TO_LANG').map((lang) => {
     const messageData = {
       text: text,
       filename: filename,
@@ -117,7 +117,7 @@ const renameImageForSave = (filename, lang) => {
  *
  * @param {object} event A Google Cloud Storage File object.
  */
-exports.processImage = async event => {
+exports.processImage = async (event) => {
   const {bucket, name} = event;
 
   if (!bucket) {
@@ -147,7 +147,7 @@ exports.processImage = async event => {
  * @param {string} {messageObject}.data The "data" property of the Cloud Pub/Sub
  * Message. This property will be a base64-encoded string that you must decode.
  */
-exports.translateText = async event => {
+exports.translateText = async (event) => {
   const pubsubData = event.data;
   const jsonStr = Buffer.from(pubsubData, 'base64').toString();
   const {text, filename, lang} = JSON.parse(jsonStr);
@@ -195,7 +195,7 @@ exports.translateText = async event => {
  * @param {string} {messageObject}.data The "data" property of the Cloud Pub/Sub
  * Message. This property will be a base64-encoded string that you must decode.
  */
-exports.saveResult = async event => {
+exports.saveResult = async (event) => {
   const pubsubData = event.data;
   const jsonStr = Buffer.from(pubsubData, 'base64').toString();
   const {text, filename, lang} = JSON.parse(jsonStr);
diff --git a/functions/ocr/app/test/index.test.js b/functions/ocr/app/test/index.test.js
index 6ad9033edc..0f1fe7391d 100644
--- a/functions/ocr/app/test/index.test.js
+++ b/functions/ocr/app/test/index.test.js
@@ -34,12 +34,12 @@ const errorMsg = (name, propertyName) => {
   return `${name} not provided. Make sure you have a "${propertyName}" property in your request`;
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
@@ -153,12 +153,7 @@ describe('saveResult', () => {
       assert.ok(console.log.calledWith('File saved.'));
 
       // Check file was actually saved
-      assert.ok(
-        storage
-          .bucket(RESULT_BUCKET)
-          .file(newFilename)
-          .exists()
-      );
+      assert.ok(storage.bucket(RESULT_BUCKET).file(newFilename).exists());
     });
   });
 });
diff --git a/functions/pubsub/index.js b/functions/pubsub/index.js
index 241f6a859c..f306ae8993 100644
--- a/functions/pubsub/index.js
+++ b/functions/pubsub/index.js
@@ -77,7 +77,7 @@ exports.publish = async (req, res) => {
  * @param {object} pubsubMessage The Cloud Pub/Sub Message object.
  * @param {string} pubsubMessage.data The "data" property of the Cloud Pub/Sub Message.
  */
-exports.subscribe = pubsubMessage => {
+exports.subscribe = (pubsubMessage) => {
   // Print out the data from Pub/Sub, to prove that it worked
   console.log(Buffer.from(pubsubMessage.data, 'base64').toString());
 };
diff --git a/functions/pubsub/test/index.test.js b/functions/pubsub/test/index.test.js
index 5aba6a226c..4bcaba8f8a 100644
--- a/functions/pubsub/test/index.test.js
+++ b/functions/pubsub/test/index.test.js
@@ -29,13 +29,13 @@ const TOPIC = process.env.FUNCTIONS_TOPIC;
 const MESSAGE = 'Hello, world!';
 
 describe('functions/pubsub', () => {
-  const stubConsole = function() {
+  const stubConsole = function () {
     sinon.stub(console, `error`);
     sinon.stub(console, `log`);
   };
 
   //Restore console
-  const restoreConsole = function() {
+  const restoreConsole = function () {
     console.log.restore();
     console.error.restore();
   };
diff --git a/functions/scheduleinstance/index.js b/functions/scheduleinstance/index.js
index 9e03a42406..6e0a50bab6 100644
--- a/functions/scheduleinstance/index.js
+++ b/functions/scheduleinstance/index.js
@@ -38,7 +38,7 @@ exports.startInstancePubSub = async (event, context, callback) => {
     const options = {filter: `labels.${payload.label}`};
     const [vms] = await compute.getVMs(options);
     await Promise.all(
-      vms.map(async instance => {
+      vms.map(async (instance) => {
         if (payload.zone === instance.zone.id) {
           const [operation] = await compute
             .zone(payload.zone)
@@ -82,7 +82,7 @@ exports.stopInstancePubSub = async (event, context, callback) => {
     const options = {filter: `labels.${payload.label}`};
     const [vms] = await compute.getVMs(options);
     await Promise.all(
-      vms.map(async instance => {
+      vms.map(async (instance) => {
         if (payload.zone === instance.zone.id) {
           const [operation] = await compute
             .zone(payload.zone)
@@ -114,7 +114,7 @@ exports.stopInstancePubSub = async (event, context, callback) => {
  * @param {!object} payload the request payload to validate.
  * @return {!object} the payload object.
  */
-const _validatePayload = payload => {
+const _validatePayload = (payload) => {
   if (!payload.zone) {
     throw new Error(`Attribute 'zone' missing from payload`);
   } else if (!payload.label) {
diff --git a/functions/scheduleinstance/test/index.test.js b/functions/scheduleinstance/test/index.test.js
index 2f7bef63e2..0e1e03a001 100644
--- a/functions/scheduleinstance/test/index.test.js
+++ b/functions/scheduleinstance/test/index.test.js
@@ -21,7 +21,7 @@ const assert = require('assert');
 const getSample = () => {
   const requestPromise = sinon
     .stub()
-    .returns(new Promise(resolve => resolve('request sent')));
+    .returns(new Promise((resolve) => resolve('request sent')));
 
   return {
     program: proxyquire('../', {
@@ -46,13 +46,13 @@ const getMocks = () => {
     callback: callback,
   };
 };
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
 //Restore console
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/functions/sendgrid/index.js b/functions/sendgrid/index.js
index ed0b886f8e..d3c2bb20e6 100644
--- a/functions/sendgrid/index.js
+++ b/functions/sendgrid/index.js
@@ -34,7 +34,7 @@ const bigquery = new BigQuery();
  * @param {string} key Your SendGrid API key.
  * @returns {object} SendGrid client.
  */
-const getClient = key => {
+const getClient = (key) => {
   if (!key) {
     const error = new Error(
       'SendGrid API key not provided. Make sure you have a "sg_key" property in your request querystring'
@@ -59,7 +59,7 @@ const getClient = key => {
  * @param {string} data.body Body of the email subject line.
  * @returns {object} Payload object.
  */
-const getPayload = requestBody => {
+const getPayload = (requestBody) => {
   if (!requestBody.to) {
     const error = new Error(
       'To email address not provided. Make sure you have a "to" property in your request'
@@ -191,7 +191,7 @@ exports.sendgridEmail = async (req, res) => {
  *
  * @param {string} authorization The authorization header of the request, e.g. "Basic ZmdvOhJhcg=="
  */
-const verifyWebhook = authorization => {
+const verifyWebhook = (authorization) => {
   const basicAuth = Buffer.from(
     authorization.replace('Basic ', ''),
     'base64'
@@ -211,11 +211,11 @@ const verifyWebhook = authorization => {
  *
  * @param {*} obj Value to examine.
  */
-const fixNames = obj => {
+const fixNames = (obj) => {
   if (Array.isArray(obj)) {
     obj.forEach(fixNames);
   } else if (obj && typeof obj === 'object') {
-    Object.keys(obj).forEach(key => {
+    Object.keys(obj).forEach((key) => {
       const value = obj[key];
       fixNames(value);
       const fixedKey = key.replace('-', '_');
@@ -254,7 +254,7 @@ exports.sendgridWebhook = async (req, res) => {
 
     // Generate newline-delimited JSON
     // See https://cloud.google.com/bigquery/data-formats#json_format
-    const json = events.map(event => JSON.stringify(event)).join('\n');
+    const json = events.map((event) => JSON.stringify(event)).join('\n');
 
     // Upload a new file to Cloud Storage if we have events to save
     if (json.length) {
@@ -301,7 +301,7 @@ const getTable = async () => {
  * @param {string} [event.data.timeDeleted] Time the file was deleted if this is a deletion event.
  * @see https://cloud.google.com/storage/docs/json_api/v1/objects#resource
  */
-exports.sendgridLoad = async event => {
+exports.sendgridLoad = async (event) => {
   const file = event.data;
 
   if (file.resourceState === 'not_exists') {
diff --git a/functions/sendgrid/test/index.test.js b/functions/sendgrid/test/index.test.js
index 322c6a0f3d..d8609b6f3c 100644
--- a/functions/sendgrid/test/index.test.js
+++ b/functions/sendgrid/test/index.test.js
@@ -117,7 +117,7 @@ const getMocks = () => {
     headers: {},
     query: {},
     body: {},
-    get: function(header) {
+    get: function (header) {
       return this.headers[header];
     },
   };
@@ -127,11 +127,11 @@ const getMocks = () => {
     send: sinon.stub().returnsThis(),
     json: sinon.stub().returnsThis(),
     end: sinon.stub().returnsThis(),
-    status: function(statusCode) {
+    status: function (statusCode) {
       this.statusCode = statusCode;
       return this;
     },
-    set: function(header, value) {
+    set: function (header, value) {
       this.headers[header] = value;
       return this;
     },
@@ -143,7 +143,7 @@ const getMocks = () => {
     res: res,
   };
 };
-const stubConsole = function() {
+const stubConsole = function () {
   if (
     typeof console.log.restore !== `function` &&
     typeof console.error.restore !== `function`
@@ -154,7 +154,7 @@ const stubConsole = function() {
 };
 
 //Restore console
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/functions/slack/index.js b/functions/slack/index.js
index 485b05076e..c8c4ac9433 100644
--- a/functions/slack/index.js
+++ b/functions/slack/index.js
@@ -92,7 +92,7 @@ const formatSlackMessage = (query, response) => {
  * @param {string} req.headers Headers Slack SDK uses to authenticate request.
  * @param {string} req.rawBody Raw body of webhook request to check signature against.
  */
-const verifyWebhook = req => {
+const verifyWebhook = (req) => {
   const signature = {
     signingSecret: config.SLACK_SECRET,
     requestSignature: req.headers['x-slack-signature'],
@@ -114,7 +114,7 @@ const verifyWebhook = req => {
  *
  * @param {string} query The user's search query.
  */
-const makeSearchRequest = query => {
+const makeSearchRequest = (query) => {
   return new Promise((resolve, reject) => {
     kgsearch.entities.search(
       {
diff --git a/functions/slack/test/index.test.js b/functions/slack/test/index.test.js
index 2626f4be23..bd4314baa6 100644
--- a/functions/slack/test/index.test.js
+++ b/functions/slack/test/index.test.js
@@ -60,7 +60,7 @@ const getMocks = () => {
     headers: {},
     query: {},
     body: {},
-    get: function(header) {
+    get: function (header) {
       return this.headers[header];
     },
   };
@@ -70,11 +70,11 @@ const getMocks = () => {
     send: sinon.stub().returnsThis(),
     json: sinon.stub().returnsThis(),
     end: sinon.stub().returnsThis(),
-    status: function(statusCode) {
+    status: function (statusCode) {
       this.statusCode = statusCode;
       return this;
     },
-    set: function(header, value) {
+    set: function (header, value) {
       this.headers[header] = value;
       return this;
     },
@@ -87,13 +87,13 @@ const getMocks = () => {
   };
 };
 
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
 //Restore console
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/functions/spanner/index.js b/functions/spanner/index.js
index 5dc4bcc88b..48a49960da 100644
--- a/functions/spanner/index.js
+++ b/functions/spanner/index.js
@@ -46,8 +46,8 @@ exports.get = async (req, res) => {
   // Execute the query
   try {
     const results = await database.run(query);
-    const rows = results[0].map(row => row.toJSON());
-    rows.forEach(row => {
+    const rows = results[0].map((row) => row.toJSON());
+    rows.forEach((row) => {
       res.write(
         `SingerId: ${row.SingerId}, ` +
           `AlbumId: ${row.AlbumId}, ` +
diff --git a/functions/spanner/test/index.test.js b/functions/spanner/test/index.test.js
index cb790ed343..2bd57842c2 100644
--- a/functions/spanner/test/index.test.js
+++ b/functions/spanner/test/index.test.js
@@ -36,7 +36,7 @@ const query = {
 };
 
 const getSample = () => {
-  const resultsMock = entities.map(row => {
+  const resultsMock = entities.map((row) => {
     return {toJSON: sinon.stub().returns(row)};
   });
   const databaseMock = {
diff --git a/functions/speech-to-speech/functions/index.js b/functions/speech-to-speech/functions/index.js
index a6c357d654..bbc8ee2860 100644
--- a/functions/speech-to-speech/functions/index.js
+++ b/functions/speech-to-speech/functions/index.js
@@ -70,13 +70,13 @@ exports.speechTranslate = functions.https.onRequest(
       // The data object contains one or more recognition
       // alternatives ordered by accuracy.
       const transcription = sttResponse.results
-        .map(result => result.alternatives[0].transcript)
+        .map((result) => result.alternatives[0].transcript)
         .join('\n');
       responseBody.transcription = transcription;
       responseBody.gcsBucket = outputBucket;
 
       const translations = [];
-      supportedLanguageCodes.forEach(async languageCode => {
+      supportedLanguageCodes.forEach(async (languageCode) => {
         const translation = {languageCode: languageCode};
         const outputFilename =
           request.body.outputFilename ||
@@ -176,15 +176,12 @@ const callTextToSpeech = (targetLocale, data) => {
 const uploadToCloudStorage = (path, contents) => {
   console.log(`Uploading audio file to ${path}`);
 
-  return storageClient
-    .bucket(outputBucket)
-    .file(path)
-    .save(contents);
+  return storageClient.bucket(outputBucket).file(path).save(contents);
 };
 // [END upload_to_cloud_storage]
 
 // [START validate_request]
-const validateRequest = request => {
+const validateRequest = (request) => {
   return new Promise((resolve, reject) => {
     if (!request.body.encoding) {
       reject(new Error('Invalid encoding.'));
diff --git a/functions/speech-to-speech/functions/test/index.test.js b/functions/speech-to-speech/functions/test/index.test.js
index 2476443393..efc5ddc70d 100644
--- a/functions/speech-to-speech/functions/test/index.test.js
+++ b/functions/speech-to-speech/functions/test/index.test.js
@@ -203,7 +203,7 @@ describe('speechTranslate tests', () => {
         assert.strictEqual(response.statusCode, 200);
 
         // Test transcription
-        response.body.translations.forEach(translation => {
+        response.body.translations.forEach((translation) => {
           assert.ifError(translation.error);
         });
         assert.strictEqual(
diff --git a/functions/sql/test/index.test.js b/functions/sql/test/index.test.js
index 17289cd1d9..dc000480a3 100644
--- a/functions/sql/test/index.test.js
+++ b/functions/sql/test/index.test.js
@@ -20,7 +20,7 @@ const proxyquire = require(`proxyquire`);
 
 const INSTANCE_PREFIX = `nodejs-docs-samples:us-central1:integration-tests-instance`;
 
-const getProgram = env => {
+const getProgram = (env) => {
   return proxyquire(`../`, {
     process: {
       env: env,
@@ -45,7 +45,7 @@ describe('functions_sql_mysql', () => {
     program.mysqlDemo(null, resMock);
 
     // Give the query time to complete
-    await new Promise(resolve => {
+    await new Promise((resolve) => {
       setTimeout(resolve, 1500);
     });
 
@@ -74,7 +74,7 @@ describe('functions_sql_postgres', () => {
     program.postgresDemo(null, resMock);
 
     // Give the query time to complete
-    await new Promise(resolve => {
+    await new Promise((resolve) => {
       setTimeout(resolve, 1500);
     });
 
diff --git a/functions/tips/index.js b/functions/tips/index.js
index 0a9e97e4b4..579fe88f04 100644
--- a/functions/tips/index.js
+++ b/functions/tips/index.js
@@ -92,10 +92,10 @@ exports.connectionPooling = (req, res) => {
       method: 'GET',
       agent: agent,
     },
-    resInner => {
+    (resInner) => {
       let rawData = '';
       resInner.setEncoding('utf8');
-      resInner.on('data', chunk => {
+      resInner.on('data', (chunk) => {
         rawData += chunk;
       });
       resInner.on('end', () => {
@@ -103,7 +103,7 @@ exports.connectionPooling = (req, res) => {
       });
     }
   );
-  req.on('error', e => {
+  req.on('error', (e) => {
     res.status(500).send(`Error: ${e.message}`);
   });
   req.end();
@@ -144,7 +144,7 @@ exports.avoidInfiniteRetries = (event, callback) => {
  * @param {object} event.data Data included with the event.
  * @param {object} event.data.retry User-supplied parameter that tells the function whether to retry.
  */
-exports.retryPromise = event => {
+exports.retryPromise = (event) => {
   const tryAgain = !!event.data.retry;
 
   if (tryAgain) {
@@ -193,7 +193,7 @@ const pubsub = new PubSub();
 exports.gcpApiCall = (req, res) => {
   const topic = pubsub.topic(req.body.topic);
 
-  topic.publish(Buffer.from('Test message'), err => {
+  topic.publish(Buffer.from('Test message'), (err) => {
     if (err) {
       res.status(500).send(`Error publishing the message: ${err}`);
     } else {
diff --git a/functions/tips/test/index.test.js b/functions/tips/test/index.test.js
index 45e8908d37..4603efea46 100644
--- a/functions/tips/test/index.test.js
+++ b/functions/tips/test/index.test.js
@@ -18,13 +18,13 @@ const sinon = require(`sinon`);
 const assert = require(`assert`);
 
 const sample = require(`../`);
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
 //Restore console
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
@@ -51,7 +51,7 @@ describe('functions_tips_retry', () => {
     }
   });
 
-  it('should demonstrate retry behavior for a callback', done => {
+  it('should demonstrate retry behavior for a callback', (done) => {
     const cb = sinon.stub();
     const err = new Error('Error!');
 
@@ -90,7 +90,7 @@ describe('functions_tips_gcp_apis', () => {
 
     // Instead of modifying the sample to return a promise,
     // use a delay here and keep the sample idiomatic
-    await new Promise(resolve => setTimeout(resolve, 1000));
+    await new Promise((resolve) => setTimeout(resolve, 1000));
 
     assert.ok(resMock.status.calledOnce);
     assert.ok(resMock.status.calledWith(200));
diff --git a/functions/tokenservice/functions/index.js b/functions/tokenservice/functions/index.js
index 56a3a1ae7d..2bf6a0c30f 100644
--- a/functions/tokenservice/functions/index.js
+++ b/functions/tokenservice/functions/index.js
@@ -41,7 +41,7 @@ const generateAccessToken = (
   // With the service account's credentials, we can make a request to generate
   // a new token for a 2nd service account that only has the permission to
   // act as a Dialogflow Client
-  return new Promise(resolve => {
+  return new Promise((resolve) => {
     const post_options = {
       host: 'iamcredentials.googleapis.com',
       path:
@@ -55,9 +55,9 @@ const generateAccessToken = (
 
     // Set up the request
     let oauthToken = '';
-    const post_req = https.request(post_options, res => {
+    const post_req = https.request(post_options, (res) => {
       res.setEncoding('utf8');
-      res.on('data', chunk => {
+      res.on('data', (chunk) => {
         oauthToken += chunk;
       });
       res.on('end', () => {
@@ -67,7 +67,7 @@ const generateAccessToken = (
       });
     });
 
-    post_req.on('error', e => {
+    post_req.on('error', (e) => {
       console.log('ERROR generating new token', e.message);
       return 'Error retrieving token';
     });
@@ -87,8 +87,8 @@ const generateAccessToken = (
 // [END generate_token]
 
 // [START retrieve_credentials]
-const retrieveCredentials = context => {
-  return new Promise(resolve => {
+const retrieveCredentials = (context) => {
+  return new Promise((resolve) => {
     // To create a new access token, we first have to retrieve the credentials
     // of the service account that will make the generateTokenRequest().
     // To do that, we will use the App Engine Default Service Account.
@@ -99,10 +99,10 @@ const retrieveCredentials = context => {
       headers: {'Metadata-Flavor': 'Google'},
     };
 
-    const get_req = http.get(options, res => {
+    const get_req = http.get(options, (res) => {
       let body = '';
 
-      res.on('data', chunk => {
+      res.on('data', (chunk) => {
         body += chunk;
       });
 
@@ -116,7 +116,7 @@ const retrieveCredentials = context => {
         return resolve(result);
       });
     });
-    get_req.on('error', e => {
+    get_req.on('error', (e) => {
       //console.log('Error retrieving credentials', e.message);
       return `Error retrieving token${e.message}`;
     });
@@ -128,7 +128,7 @@ exports.retrieveCredentials = retrieveCredentials;
 
 // [START validate_token]
 // This method verifies the token expiry by validating against current time
-const isValid = expiryTime => {
+const isValid = (expiryTime) => {
   const currentDate = new Date();
   const expirationDate = new Date(expiryTime);
   // If within 5 minutes of expiration, return false
diff --git a/functions/tokenservice/functions/package.json b/functions/tokenservice/functions/package.json
index fc5cd5d025..8fa678a986 100644
--- a/functions/tokenservice/functions/package.json
+++ b/functions/tokenservice/functions/package.json
@@ -28,7 +28,7 @@
     "eslint-plugin-prettier": "^3.1.0",
     "eslint-plugin-promise": "^4.0.1",
     "mocha": "^7.0.0",
-    "prettier": "1.19.1",
+    "prettier": "2.0.2",
     "supertest": "^4.0.0"
   },
   "engines": {
diff --git a/functions/tokenservice/functions/test/index.test.js b/functions/tokenservice/functions/test/index.test.js
index c3275ccbec..8fbca968e2 100644
--- a/functions/tokenservice/functions/test/index.test.js
+++ b/functions/tokenservice/functions/test/index.test.js
@@ -42,7 +42,7 @@ const contextValue = (uid = 'test-uid', email_verified = true) => ({
   },
 });
 
-const handleLinuxFailures = async proc => {
+const handleLinuxFailures = async (proc) => {
   try {
     return await proc;
   } catch (err) {
diff --git a/healthcare/fhir/fhir_resources.js b/healthcare/fhir/fhir_resources.js
index 2dfabb4c9d..b5e22c2a69 100644
--- a/healthcare/fhir/fhir_resources.js
+++ b/healthcare/fhir/fhir_resources.js
@@ -196,8 +196,8 @@ require(`yargs`) // eslint-disable-line
     `createResource <datasetId> <fhirStoreId> <resourceType>`,
     `Creates a new resource in a FHIR store.`,
     {},
-    opts => {
-      const cb = token => {
+    (opts) => {
+      const cb = (token) => {
         createResource(
           token,
           opts.projectId,
@@ -214,8 +214,8 @@ require(`yargs`) // eslint-disable-line
     `patchResource <datasetId> <fhirStoreId> <resourceType> <resourceId>`,
     `Patches an existing resource in a FHIR store.`,
     {},
-    opts => {
-      const cb = token => {
+    (opts) => {
+      const cb = (token) => {
         patchResource(
           token,
           opts.projectId,
@@ -233,8 +233,8 @@ require(`yargs`) // eslint-disable-line
     `executeBundle <datasetId> <fhirStoreId> <bundleFile>`,
     `Executes all the requests in the given Bundle.`,
     {},
-    opts => {
-      const cb = token => {
+    (opts) => {
+      const cb = (token) => {
         executeBundle(
           token,
           opts.projectId,
diff --git a/healthcare/sleep.js b/healthcare/sleep.js
index 531a29619b..d7bbb893c3 100644
--- a/healthcare/sleep.js
+++ b/healthcare/sleep.js
@@ -14,8 +14,8 @@
 
 'use strict';
 
-const sleep = ms => {
-  return new Promise(resolve => setTimeout(resolve, ms));
+const sleep = (ms) => {
+  return new Promise((resolve) => setTimeout(resolve, ms));
 };
 
 module.exports = sleep;
diff --git a/iot/http_example/cloudiot_http_example.js b/iot/http_example/cloudiot_http_example.js
index b33ce24b55..9b0459fd4e 100644
--- a/iot/http_example/cloudiot_http_example.js
+++ b/iot/http_example/cloudiot_http_example.js
@@ -161,7 +161,7 @@ const publishAsync = (authToken, messageCount, numMessages) => {
     json: true,
     method: 'POST',
     retries: 5,
-    shouldRetryFn: function(incomingHttpMessage) {
+    shouldRetryFn: function (incomingHttpMessage) {
       return incomingHttpMessage.statusMessage !== 'OK';
     },
   };
@@ -212,7 +212,7 @@ const getConfig = (authToken, version) => {
     },
     json: true,
     retries: 5,
-    shouldRetryFn: function(incomingHttpMessage) {
+    shouldRetryFn: function (incomingHttpMessage) {
       console.log('Retry?');
       return incomingHttpMessage.statusMessage !== 'OK';
     },
diff --git a/iot/manager/manager.js b/iot/manager/manager.js
index 29a29dd35e..53b527f03a 100644
--- a/iot/manager/manager.js
+++ b/iot/manager/manager.js
@@ -33,7 +33,7 @@ if (client === undefined) {
 }
 
 // Configures the topic for Cloud IoT Core.
-const setupIotTopic = async topicName => {
+const setupIotTopic = async (topicName) => {
   const {PubSub} = require('@google-cloud/pubsub');
 
   const pubsub = new PubSub();
@@ -52,7 +52,7 @@ const setupIotTopic = async topicName => {
     members: [serviceAccount],
   };
 
-  policy.bindings.forEach(_binding => {
+  policy.bindings.forEach((_binding) => {
     if (_binding.role === binding.role) {
       binding = _binding;
       hasRole = true;
@@ -78,7 +78,7 @@ const setupIotTopic = async topicName => {
   }
 };
 
-const createIotTopic = async topicName => {
+const createIotTopic = async (topicName) => {
   // Imports the Google Cloud client library
   const {PubSub} = require('@google-cloud/pubsub');
 
@@ -889,7 +889,7 @@ const getRegistry = async (client, registryId, projectId, cloudRegion) => {
 
 // Returns an authorized API client by discovering the Cloud IoT Core API with
 // the provided API key.
-const getClient = async serviceAccountJson => {
+const getClient = async (serviceAccountJson) => {
   // the getClient method looks for the GCLOUD_PROJECT and GOOGLE_APPLICATION_CREDENTIALS
   // environment variables if serviceAccountJson is not passed in
   const authClient = await google.auth.getClient({
@@ -941,10 +941,10 @@ const getIamPolicy = async (client, registryId, projectId, cloudRegion) => {
     console.log('ETAG:', etag);
     bindings = bindings || [];
 
-    bindings.forEach(_binding => {
+    bindings.forEach((_binding) => {
       console.log(`Role: ${_binding.role}`);
       _binding.members || (_binding.members = []);
-      _binding.members.forEach(_member => {
+      _binding.members.forEach((_member) => {
         console.log(`\t${_member}`);
       });
     });
@@ -1003,10 +1003,10 @@ const setIamPolicy = async (
     console.log('ETAG:', etag);
     bindings = bindings || [];
 
-    bindings.forEach(_binding => {
+    bindings.forEach((_binding) => {
       console.log(`Role: ${_binding.role}`);
       _binding.members || (_binding.members = []);
-      _binding.members.forEach(_member => {
+      _binding.members.forEach((_member) => {
         console.log(`\t${_member}`);
       });
     });
@@ -1280,7 +1280,7 @@ const listGateways = async (client, projectId, cloudRegion, registryId) => {
     });
     const devices = responses[0];
 
-    devices.forEach(device => {
+    devices.forEach((device) => {
       if (
         device.gatewayConfig !== undefined &&
         device.gatewayConfig.gatewayType === 'GATEWAY'
@@ -1411,7 +1411,7 @@ require(`yargs`) // eslint-disable-line
     `createRsa256Device <deviceId> <registryId> <rsaPath>`,
     `Creates an RSA256 device.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await createRsaDevice(
         client,
@@ -1427,7 +1427,7 @@ require(`yargs`) // eslint-disable-line
     `createEs256Device <deviceId> <registryId> <esPath>`,
     `Creates an ES256 device.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await createEsDevice(
         client,
@@ -1443,7 +1443,7 @@ require(`yargs`) // eslint-disable-line
     `createUnauthDevice <deviceId> <registryId>`,
     `Creates a device without authorization.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await createUnauthDevice(
         client,
@@ -1472,7 +1472,7 @@ require(`yargs`) // eslint-disable-line
         type: 'string',
       },
     },
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await createDevice(
         client,
@@ -1489,7 +1489,7 @@ require(`yargs`) // eslint-disable-line
     `createRegistry <registryId> <pubsubTopic>`,
     `Creates a device registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await createRegistry(
         client,
@@ -1504,7 +1504,7 @@ require(`yargs`) // eslint-disable-line
     `lookupRegistry <registryId>`,
     `Gets a device registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await lookupRegistry(
         client,
@@ -1518,19 +1518,19 @@ require(`yargs`) // eslint-disable-line
     `createIotTopic <pubsubTopic>`,
     `Creates and configures a PubSub topic for Cloud IoT Core.`,
     {},
-    opts => createIotTopic(opts.pubsubTopic)
+    (opts) => createIotTopic(opts.pubsubTopic)
   )
   .command(
     `setupIotTopic <pubsubTopic>`,
     `Configures the PubSub topic for Cloud IoT Core.`,
     {},
-    opts => setupIotTopic(opts.pubsubTopic)
+    (opts) => setupIotTopic(opts.pubsubTopic)
   )
   .command(
     `deleteDevice <deviceId> <registryId>`,
     `Deletes a device from the device registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await deleteDevice(
         client,
@@ -1545,7 +1545,7 @@ require(`yargs`) // eslint-disable-line
     `clearRegistry <registryId>`,
     `!!Be careful! Removes all devices and then deletes a device registry!!`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await clearRegistry(
         client,
@@ -1559,7 +1559,7 @@ require(`yargs`) // eslint-disable-line
     `deleteRegistry <registryId>`,
     `Deletes a device registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await deleteRegistry(
         client,
@@ -1573,7 +1573,7 @@ require(`yargs`) // eslint-disable-line
     `getDevice <deviceId> <registryId>`,
     `Retrieves device info given a device ID.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await getDevice(
         client,
@@ -1588,7 +1588,7 @@ require(`yargs`) // eslint-disable-line
     `getDeviceConfigs <deviceId> <registryId>`,
     `Retrieves device configurations given a device ID.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       getDeviceConfigs(
         client,
@@ -1603,7 +1603,7 @@ require(`yargs`) // eslint-disable-line
     `getDeviceState <deviceId> <registryId>`,
     `Retrieves device state given a device ID.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       getDeviceState(
         client,
@@ -1618,7 +1618,7 @@ require(`yargs`) // eslint-disable-line
     `getRegistry <registryId>`,
     `Retrieves a registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await getRegistry(
         client,
@@ -1632,7 +1632,7 @@ require(`yargs`) // eslint-disable-line
     `listDevices <registryId>`,
     `Lists the devices in a given registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await listDevices(
         client,
@@ -1646,7 +1646,7 @@ require(`yargs`) // eslint-disable-line
     `listRegistries`,
     `Lists the registries in a given project.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await listRegistries(client, opts.projectId, opts.cloudRegion);
     }
@@ -1655,7 +1655,7 @@ require(`yargs`) // eslint-disable-line
     `patchEs256 <deviceId> <registryId> <es256Path>`,
     `Patches a device with ES256 authorization credentials.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await patchEs256ForAuth(
         client,
@@ -1671,7 +1671,7 @@ require(`yargs`) // eslint-disable-line
     `patchRsa256 <deviceId> <registryId> <rsa256Path>`,
     `Patches a device with RSA256 authentication credentials.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await patchRsa256ForAuth(
         client,
@@ -1687,7 +1687,7 @@ require(`yargs`) // eslint-disable-line
     `setConfig <deviceId> <registryId> <configuration> <version>`,
     `Sets a devices configuration to the specified data.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await setDeviceConfig(
         client,
@@ -1704,7 +1704,7 @@ require(`yargs`) // eslint-disable-line
     `sendCommand <deviceId> <registryId> <commandMsg>`,
     `Sends a command message to a device subscribed to the commands topic`,
     {},
-    async opts => {
+    async (opts) => {
       await sendCommand(
         opts.deviceId,
         opts.registryId,
@@ -1718,7 +1718,7 @@ require(`yargs`) // eslint-disable-line
     `getIamPolicy <registryId>`,
     `Gets the IAM permissions for a given registry`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await getIamPolicy(
         client,
@@ -1732,7 +1732,7 @@ require(`yargs`) // eslint-disable-line
     `setIamPolicy <registryId> <member> <role>`,
     `Gets the IAM permissions for a given registry`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await setIamPolicy(
         client,
@@ -1789,7 +1789,7 @@ require(`yargs`) // eslint-disable-line
         type: 'string',
       },
     },
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await createGateway(
         client,
@@ -1806,7 +1806,7 @@ require(`yargs`) // eslint-disable-line
     `listGateways <registryId>`,
     `Lists gateways in a registry.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await listGateways(
         client,
@@ -1820,7 +1820,7 @@ require(`yargs`) // eslint-disable-line
     `bindDeviceToGateway <registryId> <gatewayId> <deviceId>`,
     `Binds a device to a gateway`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await bindDeviceToGateway(
         client,
@@ -1836,7 +1836,7 @@ require(`yargs`) // eslint-disable-line
     `unbindDeviceFromGateway <registryId> <gatewayId> <deviceId>`,
     `Unbinds a device from a gateway`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await unbindDeviceFromGateway(
         client,
@@ -1852,7 +1852,7 @@ require(`yargs`) // eslint-disable-line
     `unbindDeviceFromAllGateways <registryId> <deviceId>`,
     `Unbinds a device from all gateways`,
     {},
-    async opts => {
+    async (opts) => {
       await unbindDeviceFromAllGateways(
         opts.projectId,
         opts.cloudRegion,
@@ -1865,7 +1865,7 @@ require(`yargs`) // eslint-disable-line
     `unbindAllDevices <registryId>`,
     `Unbinds all devices in a given registry. Mainly for clearing registries`,
     {},
-    async opts => {
+    async (opts) => {
       await unbindAllDevices(opts.projectId, opts.cloudRegion, opts.registryId);
     }
   )
@@ -1873,7 +1873,7 @@ require(`yargs`) // eslint-disable-line
     `listDevicesForGateway <registryId> <gatewayId>`,
     `Lists devices in a gateway.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await listDevicesForGateway(
         client,
@@ -1888,7 +1888,7 @@ require(`yargs`) // eslint-disable-line
     `listGatewaysForDevice <registryId> <deviceId>`,
     `Lists gateways for a given device.`,
     {},
-    async opts => {
+    async (opts) => {
       const client = await getClient(opts.serviceAccount);
       await listGatewaysForDevice(
         client,
diff --git a/iot/mqtt_example/cloudiot_mqtt_example_nodejs.js b/iot/mqtt_example/cloudiot_mqtt_example_nodejs.js
index 623f24d995..bfdddc881c 100644
--- a/iot/mqtt_example/cloudiot_mqtt_example_nodejs.js
+++ b/iot/mqtt_example/cloudiot_mqtt_example_nodejs.js
@@ -91,7 +91,7 @@ const publishAsync = (
     // Publish "payload" to the MQTT topic. qos=1 means at least once delivery.
     // Cloud IoT Core also supports qos=0 for at most once delivery.
     console.log('Publishing message:', payload);
-    client.publish(mqttTopic, payload, {qos: 1}, err => {
+    client.publish(mqttTopic, payload, {qos: 1}, (err) => {
       if (!err) {
         shouldBackoff = false;
         backoffTime = MINIMUM_BACKOFF_TIME;
@@ -118,7 +118,7 @@ const publishAsync = (
         client = mqtt.connect(connectionArgs);
         // [END iot_mqtt_jwt_refresh]
 
-        client.on('connect', success => {
+        client.on('connect', (success) => {
           console.log('connect');
           if (!success) {
             console.log('Client not connected...');
@@ -139,7 +139,7 @@ const publishAsync = (
           shouldBackoff = true;
         });
 
-        client.on('error', err => {
+        client.on('error', (err) => {
           console.log('error', err);
         });
 
@@ -230,7 +230,7 @@ const mqttDeviceDemo = (
   // same as the device registry's Cloud Pub/Sub topic.
   const mqttTopic = `/devices/${deviceId}/${messageType}`;
 
-  client.on('connect', success => {
+  client.on('connect', (success) => {
     console.log('connect');
     if (!success) {
       console.log('Client not connected...');
@@ -244,7 +244,7 @@ const mqttDeviceDemo = (
     shouldBackoff = true;
   });
 
-  client.on('error', err => {
+  client.on('error', (err) => {
     console.log('error', err);
   });
 
@@ -280,7 +280,7 @@ const attachDevice = (deviceId, client, jwt) => {
     attachPayload = `{ 'authorization' : ${jwt} }`;
   }
 
-  client.publish(attachTopic, attachPayload, {qos: 1}, err => {
+  client.publish(attachTopic, attachPayload, {qos: 1}, (err) => {
     if (!err) {
       shouldBackoff = false;
       backoffTime = MINIMUM_BACKOFF_TIME;
@@ -301,7 +301,7 @@ const detachDevice = (deviceId, client, jwt) => {
     detachPayload = `{ 'authorization' : ${jwt} }`;
   }
 
-  client.publish(detachTopic, detachPayload, {qos: 1}, err => {
+  client.publish(detachTopic, detachPayload, {qos: 1}, (err) => {
     if (!err) {
       shouldBackoff = false;
       backoffTime = MINIMUM_BACKOFF_TIME;
@@ -361,7 +361,7 @@ const publishAsyncGateway = (
     // Publish "payload" to the MQTT topic. qos=1 means at least once delivery.
     // Cloud IoT Core also supports qos=0 for at most once delivery.
     console.log(`Publishing message: ${payload} to ${mqttTopic}`);
-    client.publish(mqttTopic, payload, {qos: 1}, err => {
+    client.publish(mqttTopic, payload, {qos: 1}, (err) => {
       if (!err) {
         shouldBackoff = false;
         backoffTime = MINIMUM_BACKOFF_TIME;
@@ -440,7 +440,7 @@ const sendDataFromBoundDevice = (
   const iatTime = parseInt(Date.now() / 1000);
   const client = mqtt.connect(connectionArgs);
 
-  client.on('connect', success => {
+  client.on('connect', (success) => {
     if (!success) {
       console.log('Client not connected...');
     } else if (!publishChainInProgress) {
@@ -471,7 +471,7 @@ const sendDataFromBoundDevice = (
     shouldBackoff = true;
   });
 
-  client.on('error', err => {
+  client.on('error', (err) => {
     console.log('error', err);
   });
 
@@ -528,7 +528,7 @@ const listenForConfigMessages = (
   // Create a client, and connect to the Google MQTT bridge.
   const client = mqtt.connect(connectionArgs);
 
-  client.on('connect', success => {
+  client.on('connect', (success) => {
     if (!success) {
       console.log('Client not connected...');
     } else {
@@ -554,7 +554,7 @@ const listenForConfigMessages = (
     shouldBackoff = true;
   });
 
-  client.on('error', err => {
+  client.on('error', (err) => {
     console.log('error', err);
   });
 
@@ -615,7 +615,7 @@ const listenForErrorMessages = (
   // Create a client, and connect to the Google MQTT bridge.
   const client = mqtt.connect(connectionArgs);
 
-  client.on('connect', success => {
+  client.on('connect', (success) => {
     if (!success) {
       console.log('Client not connected...');
     } else {
@@ -638,7 +638,7 @@ const listenForErrorMessages = (
     shouldBackoff = true;
   });
 
-  client.on('error', err => {
+  client.on('error', (err) => {
     console.log('error', err);
   });
 
@@ -731,7 +731,7 @@ const {argv} = require(`yargs`)
         type: 'number',
       },
     },
-    opts => {
+    (opts) => {
       mqttDeviceDemo(
         opts.deviceId,
         opts.registryId,
@@ -763,7 +763,7 @@ const {argv} = require(`yargs`)
         type: 'number',
       },
     },
-    opts => {
+    (opts) => {
       sendDataFromBoundDevice(
         opts.deviceId,
         opts.gatewayId,
@@ -796,7 +796,7 @@ const {argv} = require(`yargs`)
         type: 'number',
       },
     },
-    opts => {
+    (opts) => {
       listenForConfigMessages(
         opts.deviceId,
         opts.gatewayId,
@@ -828,7 +828,7 @@ const {argv} = require(`yargs`)
         type: 'number',
       },
     },
-    opts => {
+    (opts) => {
       listenForErrorMessages(
         opts.deviceId,
         opts.gatewayId,
diff --git a/iot/scripts/iam.js b/iot/scripts/iam.js
index 4a60ada5fd..779ff948e8 100644
--- a/iot/scripts/iam.js
+++ b/iot/scripts/iam.js
@@ -19,7 +19,7 @@
  * For more information, see https://cloud.google.com/iot.
  */
 
-const setTopicPolicy = async topicName => {
+const setTopicPolicy = async (topicName) => {
   // Imports the Google Cloud client library
   const {PubSub} = require('@google-cloud/pubsub');
 
@@ -44,7 +44,7 @@ const setTopicPolicy = async topicName => {
     members: [serviceAccount],
   };
 
-  policy.bindings.forEach(_binding => {
+  policy.bindings.forEach((_binding) => {
     if (_binding.role === binding.role) {
       binding = _binding;
       hasRole = true;
diff --git a/jobs/v2/quickstart.js b/jobs/v2/quickstart.js
index 1f6684af36..f4a6e2b8d2 100755
--- a/jobs/v2/quickstart.js
+++ b/jobs/v2/quickstart.js
@@ -21,7 +21,7 @@ const {google} = require('googleapis');
 
 google.auth
   .getClient({scopes: ['https://www.googleapis.com/auth/jobs']})
-  .then(auth => {
+  .then((auth) => {
     // Instantiates an authorized client
     const jobs = google.jobs({
       version: 'v2',
@@ -41,7 +41,7 @@ google.auth
 
       if (companies.length) {
         console.log('Companies:');
-        companies.forEach(company => console.log(company.name));
+        companies.forEach((company) => console.log(company.name));
       } else {
         console.log(`No companies found.`);
       }
diff --git a/jobs/v3/basic-job-sample.js b/jobs/v3/basic-job-sample.js
index d8d3d938b5..dccaf4c5f0 100644
--- a/jobs/v3/basic-job-sample.js
+++ b/jobs/v3/basic-job-sample.js
@@ -40,7 +40,7 @@ const PROJECT_ID = process.env.GOOGLE_CLOUD_PROJECT;
 /**
  * Generate a basic job with given companyName.
  */
-const generateJobWithRequiredFields = companyName => {
+const generateJobWithRequiredFields = (companyName) => {
   const applicationUris = ['http://careers.google.com'];
   const description =
     'Design, develop, test, deploy, maintain and improve software.';
diff --git a/jobs/v3/batchdelete-jobs-sample.js b/jobs/v3/batchdelete-jobs-sample.js
index cc666d4915..f35f5b45fd 100644
--- a/jobs/v3/batchdelete-jobs-sample.js
+++ b/jobs/v3/batchdelete-jobs-sample.js
@@ -36,7 +36,7 @@ const PROJECT_ID = process.env.GOOGLE_CLOUD_PROJECT;
 const batchDelete = async (jobServiceClient, companyName, jobs) => {
   try {
     let batchDeleteQuery = `companyName = "${companyName}"`;
-    jobs.forEach(job => {
+    jobs.forEach((job) => {
       batchDeleteQuery += ` AND requisitionId = "${job.requisitionId}"`;
     });
 
diff --git a/jobs/v3/custom-attribute-sample.js b/jobs/v3/custom-attribute-sample.js
index 563c73156d..c4b35b206d 100644
--- a/jobs/v3/custom-attribute-sample.js
+++ b/jobs/v3/custom-attribute-sample.js
@@ -39,7 +39,7 @@ const REQUEST_META_DATA = {
 /**
  * Generate a job with a custom attribute.
  */
-const generateJobWithACustomAttribute = companyName => {
+const generateJobWithACustomAttribute = (companyName) => {
   const requisitionId = `jobWithACustomAttribute: ${new Date().getTime()}`;
   const jobTitle = 'Software Engineer';
   const applicationUrls = ['http://careers.google.com'];
@@ -70,7 +70,7 @@ const generateJobWithACustomAttribute = companyName => {
 /**
  * CustomAttributeFilter on String value CustomAttribute
  */
-const filtersOnStringValueCustomAttribute = async jobServiceClient => {
+const filtersOnStringValueCustomAttribute = async (jobServiceClient) => {
   try {
     const customAttributeFilter = 'NOT EMPTY(someFieldName1)';
     const jobQuery = {customAttributeFilter: customAttributeFilter};
@@ -97,7 +97,7 @@ const filtersOnStringValueCustomAttribute = async jobServiceClient => {
 /**
  * CustomAttributeFilter on Long value CustomAttribute
  */
-const filtersOnLongValueCustomAttribute = async jobServiceClient => {
+const filtersOnLongValueCustomAttribute = async (jobServiceClient) => {
   try {
     const customAttributeFilter =
       '(255 <= someFieldName2) AND' + ' (someFieldName2 <= 257)';
@@ -125,7 +125,7 @@ const filtersOnLongValueCustomAttribute = async jobServiceClient => {
 /**
  * CustomAttributeFilter on multiple CustomAttributes
  */
-const filtersOnMultiCustomAttributes = async jobServiceClient => {
+const filtersOnMultiCustomAttributes = async (jobServiceClient) => {
   try {
     const customAttributeFilter =
       '(someFieldName1 = "value1") AND ((255 <= someFieldName2) OR ' +
diff --git a/jobs/v3/featured-job-search-sample.js b/jobs/v3/featured-job-search-sample.js
index 5be2d18423..5d84052aef 100644
--- a/jobs/v3/featured-job-search-sample.js
+++ b/jobs/v3/featured-job-search-sample.js
@@ -34,7 +34,7 @@ const PROJECT_ID = process.env.GOOGLE_CLOUD_PROJECT;
 /**
  * Creates a job as featured.
  */
-const generateFeaturedJob = companyName => {
+const generateFeaturedJob = (companyName) => {
   const requisitionId = `"featuredJob: ${new Date().getTime()}}`;
   const jobTitle = 'Software Engineer';
   const applicationUrls = ['http://careers.google.com'];
diff --git a/jobs/v3/quickstart.js b/jobs/v3/quickstart.js
index 72cf616fd9..b5cfb20b00 100755
--- a/jobs/v3/quickstart.js
+++ b/jobs/v3/quickstart.js
@@ -58,7 +58,7 @@ google.auth.getApplicationDefault((err, authClient) => {
 
     if (companies.length) {
       console.log('Companies:');
-      companies.forEach(company => console.log(company.name));
+      companies.forEach((company) => console.log(company.name));
     } else {
       console.log(`No companies found.`);
     }
diff --git a/jobs/v3/sleep.js b/jobs/v3/sleep.js
index 531a29619b..d7bbb893c3 100644
--- a/jobs/v3/sleep.js
+++ b/jobs/v3/sleep.js
@@ -14,8 +14,8 @@
 
 'use strict';
 
-const sleep = ms => {
-  return new Promise(resolve => setTimeout(resolve, ms));
+const sleep = (ms) => {
+  return new Promise((resolve) => setTimeout(resolve, ms));
 };
 
 module.exports = sleep;
diff --git a/memorystore/redis/server.js b/memorystore/redis/server.js
index 0aff1a06dc..5e5f24bd8e 100644
--- a/memorystore/redis/server.js
+++ b/memorystore/redis/server.js
@@ -21,7 +21,7 @@ const REDISHOST = process.env.REDISHOST || 'localhost';
 const REDISPORT = process.env.REDISPORT || 6379;
 
 const client = redis.createClient(REDISPORT, REDISHOST);
-client.on('error', err => console.error('ERR:REDIS:', err));
+client.on('error', (err) => console.error('ERR:REDIS:', err));
 
 // create a server
 http
diff --git a/package.json b/package.json
index e2e8316eab..54e341bdb6 100644
--- a/package.json
+++ b/package.json
@@ -24,7 +24,7 @@
     "eslint-plugin-node": "^11.0.0",
     "eslint-plugin-prettier": "^3.1.0",
     "eslint-plugin-promise": "^4.1.1",
-    "prettier": "^1.18.2",
+    "prettier": "^2.0.0",
     "requestretry": "^4.0.0"
   }
 }
diff --git a/run/image-processing/app.js b/run/image-processing/app.js
index 2badb10b9a..09f0edb336 100644
--- a/run/image-processing/app.js
+++ b/run/image-processing/app.js
@@ -30,9 +30,7 @@ app.post('/', async (req, res) => {
   const pubSubMessage = req.body.message;
   let data;
   try {
-    data = Buffer.from(pubSubMessage.data, 'base64')
-      .toString()
-      .trim();
+    data = Buffer.from(pubSubMessage.data, 'base64').toString().trim();
     data = JSON.parse(data);
   } catch (err) {
     const msg =
diff --git a/run/image-processing/image.js b/run/image-processing/image.js
index 42f0cafb47..614147bc86 100644
--- a/run/image-processing/image.js
+++ b/run/image-processing/image.js
@@ -30,7 +30,7 @@ const {BLURRED_BUCKET_NAME} = process.env;
 
 // [START run_imageproc_handler_analyze]
 // Blurs uploaded images that are flagged as Adult or Violence.
-exports.blurOffensiveImages = async event => {
+exports.blurOffensiveImages = async (event) => {
   // This event represents the triggering Cloud Storage object.
   const object = event;
 
diff --git a/run/image-processing/test/app.test.js b/run/image-processing/test/app.test.js
index 2e5f69dfb1..89a4e14cde 100644
--- a/run/image-processing/test/app.test.js
+++ b/run/image-processing/test/app.test.js
@@ -11,11 +11,7 @@ describe('Unit Tests', () => {
 
   describe('should fail', () => {
     it(`on a Bad Request with an empty payload`, async () => {
-      await request
-        .post('/')
-        .type('json')
-        .send('')
-        .expect(400);
+      await request.post('/').type('json').send('').expect(400);
     });
 
     it(`on a Bad Request with an invalid payload`, async () => {
@@ -27,11 +23,7 @@ describe('Unit Tests', () => {
     });
 
     it(`on a Bad Request with an invalid mimetype`, async () => {
-      await request
-        .post('/')
-        .type('text')
-        .send('{message: true}')
-        .expect(400);
+      await request.post('/').type('text').send('{message: true}').expect(400);
     });
 
     it(`if the decoded message.data is not well-formed JSON`, async () => {
diff --git a/run/logging-manual/test/system.test.js b/run/logging-manual/test/system.test.js
index 75556976f9..b6d7058cc5 100644
--- a/run/logging-manual/test/system.test.js
+++ b/run/logging-manual/test/system.test.js
@@ -33,7 +33,7 @@ const getLogEntriesPolling = async (filter, max_attempts) => {
   return [];
 };
 
-const getLogEntries = async filter => {
+const getLogEntries = async (filter) => {
   const preparedFilter = `resource.type="cloud_run_revision" ${filter}`;
   const entries = await logging.getEntries({
     filter: preparedFilter,
@@ -83,7 +83,7 @@ describe('Logging', () => {
         5
       )}"`;
       const entries = await getLogEntriesPolling(filter);
-      entries.forEach(entry => {
+      entries.forEach((entry) => {
         if (entry.metadata.httpRequest) {
           requestLog = entry;
         } else {
diff --git a/run/pubsub/app.js b/run/pubsub/app.js
index 42f7482566..1bb7c6a8ad 100644
--- a/run/pubsub/app.js
+++ b/run/pubsub/app.js
@@ -27,9 +27,7 @@ app.post('/', (req, res) => {
 
   const pubSubMessage = req.body.message;
   const name = pubSubMessage.data
-    ? Buffer.from(pubSubMessage.data, 'base64')
-        .toString()
-        .trim()
+    ? Buffer.from(pubSubMessage.data, 'base64').toString().trim()
     : 'World';
 
   console.log(`Hello ${name}!`);
diff --git a/run/pubsub/test/app.test.js b/run/pubsub/test/app.test.js
index 524dc17432..7d11777053 100644
--- a/run/pubsub/test/app.test.js
+++ b/run/pubsub/test/app.test.js
@@ -34,11 +34,7 @@ describe('Unit Tests', () => {
 
   describe('should fail', () => {
     it(`on a Bad Request with an empty payload`, async () => {
-      await request
-        .post('/')
-        .type('json')
-        .send('')
-        .expect(400);
+      await request.post('/').type('json').send('').expect(400);
     });
 
     it(`on a Bad Request with an invalid payload`, async () => {
@@ -50,11 +46,7 @@ describe('Unit Tests', () => {
     });
 
     it(`on a Bad Request with an invalid mimetype`, async () => {
-      await request
-        .post('/')
-        .type('text')
-        .send('{message: true}')
-        .expect(400);
+      await request.post('/').type('text').send('{message: true}').expect(400);
     });
   });
 
diff --git a/run/system-package/app.js b/run/system-package/app.js
index 4b0c6eed6c..eb91d42236 100644
--- a/run/system-package/app.js
+++ b/run/system-package/app.js
@@ -44,7 +44,7 @@ app.get('/diagram.png', (req, res) => {
 
 // [START run_system_package_exec]
 // Generate a diagram based on a graphviz DOT diagram description.
-const createDiagram = dot => {
+const createDiagram = (dot) => {
   if (!dot) {
     throw new Error('syntax: no graphviz definition provided');
   }
diff --git a/run/system-package/test/app.test.js b/run/system-package/test/app.test.js
index 3d76d6df7f..fa82ccb021 100644
--- a/run/system-package/test/app.test.js
+++ b/run/system-package/test/app.test.js
@@ -30,7 +30,7 @@ describe('Unit Tests', () => {
         .type('text')
         .expect(400)
         .expect('Content-Type', errorContentType)
-        .expect(res => {
+        .expect((res) => {
           if (res.headers['cache-control']) {
             throw new Error('Found cache header on uncached response');
           }
@@ -44,7 +44,7 @@ describe('Unit Tests', () => {
         .query({dot: ''})
         .expect(400)
         .expect('Content-Type', errorContentType)
-        .expect(res => {
+        .expect((res) => {
           if (res.headers['cache-control']) {
             throw new Error('Found cache header on uncached response');
           }
@@ -58,7 +58,7 @@ describe('Unit Tests', () => {
         .query({dot: `digraph`})
         .expect(400)
         .expect('Content-Type', errorContentType)
-        .expect(res => {
+        .expect((res) => {
           if (res.headers['cache-control']) {
             throw new Error('Found cache header on uncached response');
           }
diff --git a/storage-transfer/system-test/transfer.test.js b/storage-transfer/system-test/transfer.test.js
index 423dc1dcd4..daa798c43e 100644
--- a/storage-transfer/system-test/transfer.test.js
+++ b/storage-transfer/system-test/transfer.test.js
@@ -89,7 +89,7 @@ after(() => {
   } catch (err) {} // ignore error
 });
 
-it('should create a storage transfer job', done => {
+it('should create a storage transfer job', (done) => {
   const options = {
     srcBucket: firstBucketName,
     destBucket: secondBucketName,
@@ -112,7 +112,7 @@ it('should create a storage transfer job', done => {
   });
 });
 
-it('should get a transferJob', done => {
+it('should get a transferJob', (done) => {
   program.getTransferJob(jobName, (err, transferJob) => {
     assert.ifError(err);
     assert.strictEqual(transferJob.name, jobName);
@@ -126,7 +126,7 @@ it('should get a transferJob', done => {
   });
 });
 
-it('should update a transferJob', done => {
+it('should update a transferJob', (done) => {
   const options = {
     job: jobName,
     field: 'status',
@@ -146,19 +146,21 @@ it('should update a transferJob', done => {
   });
 });
 
-it('should list transferJobs', done => {
+it('should list transferJobs', (done) => {
   program.listTransferJobs((err, transferJobs) => {
     assert.ifError(err);
     assert.strictEqual(
-      transferJobs.some(transferJob => transferJob.name === jobName),
+      transferJobs.some((transferJob) => transferJob.name === jobName),
       true
     );
     assert.strictEqual(
-      transferJobs.some(transferJob => transferJob.description === description),
+      transferJobs.some(
+        (transferJob) => transferJob.description === description
+      ),
       true
     );
     assert.strictEqual(
-      transferJobs.some(transferJob => transferJob.status === status),
+      transferJobs.some((transferJob) => transferJob.status === status),
       true
     );
     assert.strictEqual(
@@ -169,7 +171,7 @@ it('should list transferJobs', done => {
   });
 });
 
-it('should list transferOperations', done => {
+it('should list transferOperations', (done) => {
   program.listTransferOperations(jobName, (err, operations) => {
     assert.ifError(err);
     assert.strictEqual(Array.isArray(operations), true);
diff --git a/storage-transfer/test/transfer.test.js b/storage-transfer/test/transfer.test.js
index 911507a8a8..41ba07879e 100644
--- a/storage-transfer/test/transfer.test.js
+++ b/storage-transfer/test/transfer.test.js
@@ -74,13 +74,13 @@ const getSample = () => {
     },
   };
 };
-const stubConsole = function() {
+const stubConsole = function () {
   sinon.stub(console, `error`);
   sinon.stub(console, `log`);
 };
 
 //Restore console
-const restoreConsole = function() {
+const restoreConsole = function () {
   console.log.restore();
   console.error.restore();
 };
diff --git a/storage-transfer/transfer.js b/storage-transfer/transfer.js
index c3a40b4fe0..af8e13e88a 100644
--- a/storage-transfer/transfer.js
+++ b/storage-transfer/transfer.js
@@ -24,7 +24,7 @@ const storagetransfer = google.storagetransfer('v1');
 // [END setup]
 
 // [START auth]
-const auth = callback => {
+const auth = (callback) => {
   google.auth.getApplicationDefault((err, authClient) => {
     if (err) {
       return callback(err);
@@ -210,7 +210,7 @@ const updateTransferJob = (options, callback) => {
  *
  * @param {function} callback The callback function.
  */
-const listTransferJobs = callback => {
+const listTransferJobs = (callback) => {
   auth((err, authClient) => {
     if (err) {
       return callback(err);
@@ -328,7 +328,7 @@ const pauseTransferOperation = (transferOperationName, callback) => {
         name: transferOperationName,
         auth: authClient,
       },
-      err => {
+      (err) => {
         if (err) {
           return callback(err);
         }
@@ -359,7 +359,7 @@ const resumeTransferOperation = (transferOperationName, callback) => {
         name: transferOperationName,
         auth: authClient,
       },
-      err => {
+      (err) => {
         if (err) {
           return callback(err);
         }
@@ -385,7 +385,7 @@ const program = (module.exports = {
   getTransferOperation: getTransferOperation,
   pauseTransferOperation: pauseTransferOperation,
   resumeTransferOperation: resumeTransferOperation,
-  main: args => {
+  main: (args) => {
     // Run the command-line program
     cli.help().strict().parse(args).argv; // eslint-disable-line
   },
@@ -396,14 +396,14 @@ cli
   .command(
     'jobs <cmd> [args]',
     'Run a job command.',
-    yargs => {
+    (yargs) => {
       yargs
         .demand(2)
         .command(
           'create <srcBucket> <destBucket> <time> <date> [description]',
           'Create a transfer job.',
           {},
-          opts => {
+          (opts) => {
             program.createTransferJob(
               {
                 srcBucket: opts.srcBucket,
@@ -416,7 +416,7 @@ cli
             );
           }
         )
-        .command('get <job>', 'Get a transfer job.', {}, opts => {
+        .command('get <job>', 'Get a transfer job.', {}, (opts) => {
           program.getTransferJob(opts.job, console.log);
         })
         .command('list', 'List transfer jobs.', {}, () => {
@@ -426,7 +426,7 @@ cli
           'set <job> <field> <value>',
           'Change the status, description or transferSpec of a transfer job.',
           {},
-          opts => {
+          (opts) => {
             program.updateTransferJob(
               {
                 job: opts.job,
@@ -461,25 +461,25 @@ cli
   .command(
     'operations <cmd> [args]',
     'Run an operation command.',
-    yargs => {
+    (yargs) => {
       yargs
         .demand(2)
         .command(
           'list [job]',
           'List transfer operations, optionally filtering by a job name.',
           {},
-          opts => {
+          (opts) => {
             program.listTransferOperations(opts.job, console.log);
           }
         )
-        .command('get <operation>', 'Get a transfer operation.', {}, opts => {
+        .command('get <operation>', 'Get a transfer operation.', {}, (opts) => {
           program.getTransferOperation(opts.operation, console.log);
         })
         .command(
           'pause <operation>',
           'Pause a transfer operation.',
           {},
-          opts => {
+          (opts) => {
             program.pauseTransferOperation(opts.operation, console.log);
           }
         )
@@ -487,7 +487,7 @@ cli
           'resume <operation>',
           'Resume a transfer operation.',
           {},
-          opts => {
+          (opts) => {
             program.resumeTransferOperation(opts.operation, console.log);
           }
         )