Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(21)  |  Call(15)  |  Derive(0)  |  Import(6)

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/browser/views.py   ftw.publisher.sender(Download)
from ftw.publisher.sender.events import AfterPushEvent, QueueExecutedEvent
from ftw.publisher.sender.events import BeforeQueueExecutionEvent
from ftw.publisher.sender.interfaces import IPathBlacklist, IConfig, IQueue
from ftw.publisher.sender.utils import add_transaction_aware_status_message
from ftw.publisher.sender.utils import sendJsonToRealm
        # create Job
        portal = self.context.portal_url.getPortalObject()
        queue = IQueue(portal)
        queue.createJob('push', self.context, username)
        self.logger.info('Created "%s" Job for "%s" at %s' % (
        # create Job
        portal = self.context.portal_url.getPortalObject()
        queue = IQueue(portal)
        queue.createJob('move', self.context, username, )
        self.logger.info('Created "%s" Job for "%s" at %s' % (
        # create Job
        portal = self.context.portal_url.getPortalObject()
        queue = IQueue(portal)
        queue.createJob('delete', self.context, username)
        self.logger.info('Created "%s" Job for "%s" at %s' % (
        portal = self.context.portal_url.getPortalObject()
        self.config = IConfig(portal)
        self.queue = IQueue(portal)
        # remove job from queue
        if job in self.queue.getJobs():

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/browser/configlet.py   ftw.publisher.sender(Download)
from ftw.publisher.sender.browser.interfaces import IRealmSchema
from ftw.publisher.sender.interfaces import IConfig
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.persistence import Realm
from ftw.publisher.sender.utils import sendRequestToRealm
    def __init__(self, *args, **kwargs):
        super(PublisherConfigletView, self).__init__(*args, **kwargs)
        self.config = IConfig(self.context)
        self.queue = IQueue(self.context)
 

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/upgrades/__init__.py   ftw.publisher.sender(Download)
from ftw.publisher.sender.interfaces import IQueue
from transaction import savepoint
from zope.annotation.interfaces import IAnnotations
 
 
    """
    portal = portal_setup.portal_url.getPortalObject()
    queue = IQueue(portal)
    annotations = IAnnotations(portal)
 

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/persistence.py   ftw.publisher.sender(Download)
from ftw.publisher.sender.interfaces import IConfig
from ftw.publisher.sender.interfaces import IOverriddenRealmRegistry
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.interfaces import IRealm
from persistent import Persistent

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/tests/test_publisher_subscribers.py   ftw.publisher.sender(Download)
from Products.CMFCore.utils import getToolByName
from ftw.builder import Builder
from ftw.builder import create
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.testing import PUBLISHER_SENDER_FUNCTIONAL_TESTING
        Workflow().do_transition('publish')
 
        queue = IQueue(self.portal)
        self.assertEquals(1, queue.countJobs())
 
        Workflow().do_transition('submit')
 
        queue = IQueue(self.portal)
        self.assertEquals(0, queue.countJobs())
 
        Workflow().do_transition('revise')
 
        queue = IQueue(self.portal)
        self.assertEquals(0, queue.countJobs())
 
    def test_no_job_when_object_has_no_publisher_workflow(self):
        queue = IQueue(self.portal)
        page = create(Builder('page'))
        Plone().login().visit(page, 'delete_confirmation')
        self.assertEquals(0, queue.countJobs())

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/tests/test_simplelayout.py   ftw.publisher.sender(Download)
from Products.CMFCore.utils import getToolByName
from ftw.builder import Builder
from ftw.builder import create
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.testing import PUBLISHER_SENDER_FUNCTIONAL_TESTING
        Workflow().do_transition('publish')
 
        queue = IQueue(self.portal)
        self.assertEquals(
            2, queue.countJobs(),
        Workflow().do_transition('publish')
 
        queue = IQueue(self.portal)
        self.assertEquals(
            3, queue.countJobs(),