use FS::UID qw( dbh driver_name );
use FS::Conf;
use FS::Record qw(qsearchs qsearch str2time_sql);
+use FS::queue;
use FS::upgrade_journal;
use FS::svc_domain;
$class->_upgrade_data(%opt);
+ # New interface for async upgrades: a class can declare a
+ # "queueable_upgrade" method, which will run as part of the normal
+ # upgrade, but if the -j option is passed, will instead be run from
+ # the job queue.
+ if ( $class->can('queueable_upgrade') ) {
+ my $jobname = $class . '::queueable_upgrade';
+ my $num_jobs = FS::queue->count("job = '$jobname' and status != 'failed'");
+ if ($num_jobs > 0) {
+ warn "$class upgrade already scheduled.\n";
+ } else {
+ if ( $opt{'queue'} ) {
+ warn "Scheduling $class upgrade.\n";
+ my $job = FS::queue->new({ job => $jobname });
+ $job->insert($class, %opt);
+ } else {
+ $class->queueable_upgrade(%opt);
+ }
+ } #$num_jobs == 0
+ }
+
if ( $oldAutoCommit ) {
warn " committing\n";
dbh->commit or die dbh->errstr;