草庐IT

Multi-task

全部标签

多机器人路径规划(Multi-Agent Path Finding, MAPF)

多智能体路径规划多智能体路径规划ExampleConflict-BasedSearch(CBS)EnhancedConflict-BasedSearch(ECBS)PrioritizedPlanningusingSIPPBuildLaunchexamplelaunchNotes:代码架构Nodes1mapf_base1.1节点结构1.2订阅话题1.3发布话题1.4节点参数2goal_transformer2.1节点结构2.2订阅话题2.3发布话题2.4节点参数3plan_executor3.1节点结构3.2订阅话题3.3发布话题3.4节点参数4全局节点结构ROS插件结构多智能体路径规划多智能体

java - 安卓工作室 : Error Code 1: Gradle: Execution failed for task ':app:processDebugResources'

我想编译一个项目,我得到了Error:Gradle:Executionfailedfortask':app:processDebugResources'。这里是个异常(exception):Error:Gradle:Executionfailedfortask':app:processDebugResources'.com.android.ide.common.internal.LoggedErrorException:Failedtoruncommand:D:\devtools\adt\sdk\build-tools\21.1.1\aapt.exepackage-f--no-crun

Java 执行器 : wait for task termination.

这个问题在这里已经有了答案:Howtowaitforallthreadstofinish,usingExecutorService?(27个答案)关闭5年前。我需要提交一些任务,然后等待它们直到所有结果都可用。它们中的每一个都将一个String添加到一个Vector(默认情况下是同步的)。然后我需要为Vector中的每个结果启动一个新任务,但只有当所有以前的任务都停止工作时我才需要这样做。我想使用JavaExecutor,特别是我尝试使用Executors.newFixedThreadPool(100)以使用固定数量的线程(我有可变数量的任务,可以是10或500)但我是执行者的新手,我

python - Airflow XCOM KeyError : 'task_instance'

我正在尝试设置动态序列etl作业,它将使用XCOM从运行的第一个任务中获取数据。这是当前代码:fromairflowimportDAGfromairflow.operators.bash_operatorimportBashOperatorfromdatetimeimportdatetimeasdt,timedeltaastd,datefromairflow.modelsimportBaseOperatorfromairflow.operators.sensorsimportExternalTaskSensorfromairflow.operators.dummy_operatorim

python - Django celery : how to set task to run at specific interval programmatically

我发现我可以将任务设置为在特定时间以特定间隔运行here,但这只是在任务声明期间完成的。如何将任务设置为动态定期运行? 最佳答案 时间表是derivedfromasetting,因此在运行时似乎是不可变的。您可能可以使用TaskETAs完成您正在寻找的东西.这保证您的任务不会在期望的时间之前运行,但不保证在指定的时间运行任务——如果工作人员在指定的ETA重载,任务可能会稍后运行.如果该限制不是问题,您可以编写一个首先自行运行的任务,如:@taskdefmytask():keep_running=#Boolean,shouldthet

python - 如何使用 django-celery 配置 TASK_SERIALIZER

我正在使用django-celery,我想将TASK_SERIALIZER设置为JSON而不是pickle。我可以在每个方法的基础上通过改变我的任务装饰器来做到这一点@task到@task(serializer="json")但我想在全局范围内进行。设置TASK_SERIALIZER="json"在settings.py中不起作用。尝试运行importcelerycelery.conf.TASK_SERIALIZER="json"(隐含here)导致AttributeError:'module'objecthasnoattribute'conf'知道在通过django运行celery时

python - 导入错误 : No module named 'tasks'

我正在尝试让Celery与django一起工作以设置计划任务。我试过查看thefirststepsw/Celery和thefirststepsw/Django教程,但都没有为我工作。这是我的项目布局和相关文件:python3.5.1Django1.10celery4.0.2RabbitMQ3.6.6一次性密码19.2mysite/(projectname)polls/(myapp)tasks...mysite/__init__celerysettings...manage...我的网站/__init__.py:from__future__importabsolute_import,un

python - 我将什么参数传递给 celery 的 get_task_logger() 函数?

celery3.xdocsonlogging建议像这样设置任务记录器:fromcelery.utils.logimportget_task_loggerlogger=get_task_logger(__name__)当我这样做时,CELERYD_TASK_LOG_FORMAT被忽略,日志语句使用CELERYD_LOG_FORMAT代替,我无法使用%(task_name)s和%(task_id)s。我的任务在我的应用myapp的模块tasks中。因此,__name__是myapp.tasks。我认为问题出在celery/utils/log.py中的这些行:defget_task_logg

python - 如何等待 create_task() 创建的任务完成?

我编写了一个测试程序来尝试使用create_task(),它需要等到创建的任务完成。我尝试使用loop.run_until_complete()来等待任务完成,但它会导致带有回溯的错误。/Users/jason/.virtualenvs/xxx/bin/python3.5/Users/jason/asyncio/examples/hello_coroutine.pyTraceback(mostrecentcalllast):TestFile"/Users/jason/asyncio/examples/hello_coroutine.py",line42,inHelloWorld,isa

python - celery 节拍时间表 : run task instantly when start celery beat?

如果我使用timedelta(days=1)创建一个celerybeat时间表,第一个任务将在24小时后执行,引用celerybeat文档:Usingatimedeltafortheschedulemeansthetaskwillbesentin30secondintervals(thefirsttaskwillbesent30secondsaftercelerybeatstarts,andthenevery30secondsafterthelastrun).但事实是,在很多情况下,调度程序在启动时运行任务实际上很重要,但我没有找到允许我在celery启动后立即运行任务的选项,我不是在