|  | @@ -342,10 +342,12 @@ class PersistentScheduler(Scheduler):
 | 
	
		
			
				|  |  |          else:
 | 
	
		
			
				|  |  |              if '__version__' not in self._store:
 | 
	
		
			
				|  |  |                  self._store.clear()   # remove schedule at 2.2.2 upgrade.
 | 
	
		
			
				|  |  | +            if 'utc' not in self._store:
 | 
	
		
			
				|  |  | +                self._store.clear()   # remove schedule at 3.0.1 upgrade.
 | 
	
		
			
				|  |  |          entries = self._store.setdefault('entries', {})
 | 
	
		
			
				|  |  |          self.merge_inplace(self.app.conf.CELERYBEAT_SCHEDULE)
 | 
	
		
			
				|  |  |          self.install_default_entries(self.schedule)
 | 
	
		
			
				|  |  | -        self._store['__version__'] = __version__
 | 
	
		
			
				|  |  | +        self._store.update(__version__=__version__, utc=True)
 | 
	
		
			
				|  |  |          self.sync()
 | 
	
		
			
				|  |  |          debug('Current schedule:\n' + '\n'.join(repr(entry)
 | 
	
		
			
				|  |  |                                      for entry in entries.itervalues()))
 |