diff --git a/lib/products/crm/crm-module.coffee b/lib/products/crm/crm-module.coffee
index f63fcd0..e807c74 100644
--- a/lib/products/crm/crm-module.coffee
+++ b/lib/products/crm/crm-module.coffee
@@ -362,17 +362,22 @@ class CrmModule extends BaseModule
         if _.isFunction(cb) then cb(null,response)
     )
 
-  updateRecords: (id, records, cb) ->
+  updateRecords: (id, records, _query, cb) ->
     if not id
       throw new Error('Requires an Id to fetch')
     if not _.isObject(records)
       throw new Error('Requires record object')
 
-    query = {
+    if _.isFunction(_query)
+      cb = _query
+      _query = {}
+
+    query = _.extend({
       newFormat: 1,
       id: id,
       xmlData: @build(records)
-    }
+    }, _query)
+
     options = {
       method: 'POST'
     }
diff --git a/spec/unit/crm/crm-module-spec.coffee b/spec/unit/crm/crm-module-spec.coffee
index f87e825..40ade10 100644
--- a/spec/unit/crm/crm-module-spec.coffee
+++ b/spec/unit/crm/crm-module-spec.coffee
@@ -201,6 +201,71 @@ describe 'crm module', ->
         return next
       runs ->
         expect(r).toEqual(response)
+        
+  describe 'updateRecords', ->
+    response = next = undefined
+    id = '1234567890123456'
+    _query = {wfTrigger: 'true'}
+
+    beforeEach ->
+      spyOn(crmModule,'build').andReturn('<?xml version="1.0" encoding="UTF-8"?><crmModule/>')
+      response = new Response({})
+      next = false
+      spyOn(Request.prototype,'request').andCallFake( (cb) ->
+        setImmediate(cb,null,response)
+      )
+      spyOn(crmModule,'buildUrl').andReturn({})
+      spyOn(crmModule,'processRecord').andReturn({})
+
+    it 'requires id', ->
+      expect( () -> crmModule.updateRecords(0, record,() -> ) ).toThrow('Requires an Id to fetch')
+
+    it 'requires record object', ->
+      expect( () -> crmModule.updateRecords(id, 0, () -> ) ).toThrow('Requires record object')
+
+    it 'calls buildRecords', ->
+      crmModule.updateRecords(id, record, undefined)
+      expect(crmModule.build).toHaveBeenCalledWith(record)
+
+    it 'builds Url', ->
+      crmModule.updateRecords(id, record, undefined)
+      expect(crmModule.buildUrl).toHaveBeenCalledWith(
+        {newFormat:1, id: id, xmlData:'<?xml version="1.0" encoding="UTF-8"?><crmModule/>'},
+        ['updateRecords'],
+        {method:'POST'}
+      )
+
+    it 'builds Url with options', ->
+      crmModule.updateRecords(id, record, _query, undefined)
+      expect(crmModule.buildUrl).toHaveBeenCalledWith(
+        {newFormat:1, id: id, xmlData:'<?xml version="1.0" encoding="UTF-8"?><crmModule/>', wfTrigger: 'true'},
+        ['updateRecords'],
+        {method:'POST'}
+      )
+
+    it 'calls callback with response', ->
+      r = undefined
+      runs ->
+        crmModule.updateRecords(id, record, (err,_r) ->
+          r = _r
+          next = true
+        )
+      waitsFor ->
+        return next
+      runs ->
+        expect(r).toEqual(response)
+
+    it 'calls callback with options with response', ->
+      r = undefined
+      runs ->
+        crmModule.updateRecords(id, record, _query, (err,_r) ->
+          r = _r
+          next = true
+        )
+      waitsFor ->
+        return next
+      runs ->
+        expect(r).toEqual(response)
 
   describe 'getRecordById', ->
     next = response = undefined