diff --git a/modules/salesforce_pull/salesforce_pull.module b/modules/salesforce_pull/salesforce_pull.module
index f2c12ec..be2ebe3 100644
--- a/modules/salesforce_pull/salesforce_pull.module
+++ b/modules/salesforce_pull/salesforce_pull.module
@@ -9,6 +9,7 @@
  * Define pull queue name.
  */
 define('SALESFORCE_PULL_QUEUE', 'salesforce_pull');
+define('SALESFORCE_PULL_LOG_LEVEL', 'salesforce_pull_log_level');
 
 /**
  * Implements hook_menu().
@@ -114,6 +115,15 @@ function salesforce_cron_queue_info() {
  * Implements hook_form_FORM_ID_alter().
  */
 function salesforce_pull_form_salesforce_settings_form_alter(&$form, &$form_state, $form_id) {
+  $log_level = variable_get(SALESFORCE_PULL_LOG_LEVEL, WATCHDOG_INFO);
+  $form[SALESFORCE_PULL_LOG_LEVEL] = array(
+    '#type' => 'select',
+    '#title' => t('Pull log level'),
+    '#description' => t('Minimum watchdog severity to log when performing pulls.'),
+    '#options' => watchdog_severity_levels(),
+    '#default_value' => $log_level,
+  );
+
   $form['salesforce_pull_throttle'] = array(
     '#type' => 'textfield',
     '#title' => t('Pull throttle (seconds)'),
@@ -289,7 +299,7 @@ function salesforce_pull_get_updated_records() {
       variable_set('salesforce_pull_last_sync_' . $type, REQUEST_TIME);
     }
     else {
-      watchdog('Salesforce Pull', $results['errorCode'] . ':' . $results['message'], array(), WATCHDOG_ERROR);
+      salesforce_pull_watchdog_log($results['errorCode'] . ':' . $results['message'], array(), WATCHDOG_ERROR);
     }
   }
 }
@@ -334,7 +344,7 @@ function salesforce_pull_process_records($sf_object) {
               '%label' => $mapping_object->entity_id,
               '%sfobjectid' => $sf_object['Id'],
             ));
-          watchdog('Salesforce Pull', $message, array(), WATCHDOG_NOTICE);
+          salesforce_pull_watchdog_log($message, array(), WATCHDOG_NOTICE);
           salesforce_set_message($message, 'status', FALSE);
           entity_delete('salesforce_mapping_object', $mapping_object->salesforce_mapping_object_id);
         }
@@ -364,7 +374,7 @@ function salesforce_pull_process_records($sf_object) {
             $mapping_object->last_sync_message = t('Retrieved updates from Salesforce');
             $mapping_object->last_sync_status = SALESFORCE_MAPPING_STATUS_SUCCESS;
             $mapping_object->entity_updated = $mapping_object->last_sync = time();
-            watchdog('Salesforce Pull',
+            salesforce_pull_watchdog_log(
               'Updated entity %label associated with Salesforce Object ID: %sfid',
               array(
                 '%label' => $wrapper->label(),
@@ -382,7 +392,7 @@ function salesforce_pull_process_records($sf_object) {
             '@msg' => $e->getMessage(),
           )
         );
-        watchdog('Salesforce Pull', $message, array(), WATCHDOG_ERROR);
+        salesforce_pull_watchdog_log($message, array(), WATCHDOG_ERROR);
         salesforce_set_message($message, 'error', FALSE);
         $mapping_object->last_sync_status = SALESFORCE_MAPPING_STATUS_ERROR;
         $mapping_object->last_sync_message = t('Processing failed');
@@ -459,7 +469,7 @@ function salesforce_pull_process_records($sf_object) {
               '%sfobjectid' => $sf_object['Id'],
             )
           );
-        watchdog('Salesforce Pull', $message, array(), WATCHDOG_ERROR);
+        salesforce_pull_watchdog_log($message, array(), WATCHDOG_ERROR);
         salesforce_set_message('There were failures processing data from Salesforce. Please check the error logs.', 'error', FALSE);
         $last_sync_status = SALESFORCE_MAPPING_STATUS_ERROR;
         $last_sync_message = t('Processing failed for new record');
@@ -495,7 +505,7 @@ function salesforce_pull_process_records($sf_object) {
         'last_sync_status' => $last_sync_status,
       ));
 
-      watchdog('Salesforce Pull',
+      salesforce_pull_watchdog_log(
         'Created entity %label associated with Salesforce Object ID: %sfid',
         array(
           '%label' => $wrapper->label(),
@@ -592,7 +602,7 @@ function salesforce_pull_process_deleted_records() {
             watchdog_exception('salesforce_pull', $e);
           }
 
-          watchdog('Salesforce Pull',
+          salesforce_pull_watchdog_log(
             'Deleted entity %label with ID: %id associated with Salesforce Object ID: %sfid',
             array(
               '%label' => $entity_wrapper->label(),
@@ -674,3 +684,9 @@ function salesforce_pull_map_fields($field_maps, &$entity_wrapper, $sf_object) {
     }
   }
 }
+
+function salesforce_pull_watchdog_log($message, $variables = array(), $severity = WATCHDOG_NOTICE, $link = NULL) {
+  if ($severity <= variable_get(SALESFORCE_PULL_LOG_LEVEL, WATCHDOG_DEBUG)) {
+    watchdog('Salesforce Pull', $message, $variables, $severity, $link);
+  }
+}
